Adding missed changes after merging conflicts

GoogleCloudDataproc · Nov 1, 2024 · f18114f · f18114f
1 parent 75ec55f
commit f18114f
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git 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/...st/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java b/...st/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;