diff --git a/cloudbuild/nightly/scripts/table_write.sh b/cloudbuild/nightly/scripts/table_write.sh
index ba7fe56a..0f8771fb 100644
--- a/cloudbuild/nightly/scripts/table_write.sh
+++ b/cloudbuild/nightly/scripts/table_write.sh
@@ -46,7 +46,7 @@ then
   if [ "$IS_SQL" == True ]
   then
     echo "SQL Mode is Enabled!"
-    DESTINATION_TABLE_NAME="$DESTINATION_TABLE_NAME"-"$IS_SQL"
+    DESTINATION_TABLE_NAME="$DESTINATION_TABLE_NAME"-SQL
   fi
   source cloudbuild/nightly/scripts/bounded_table_write.sh "$PROPERTIES" "$SINK_PARALLELISM" "$IS_SQL"
 elif [ "$MODE" == "unbounded" ]
diff --git a/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java b/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
index eee29186..bd9d87b9 100644
--- a/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
+++ b/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
@@ -19,7 +19,6 @@
 package com.google.cloud.flink.bigquery.integration;
 
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
-import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.api.common.functions.MapFunction;
 import org.apache.flink.api.common.functions.RichFlatMapFunction;
 import org.apache.flink.api.common.functions.RichMapFunction;