🩹 add quotes around partitionning by PK in BigQuery Merge statement

viragtripathi · Apr 10, 2023 · 192e469 · 192e469
1 parent ca8840b
commit 192e469
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeStatementBuilder.java b/v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeStatementBuilder.java
@@ -149,7 +149,8 @@ private String buildPartitionedByPKAndSorted(
       List<String> orderByFields,
       String deletedFieldName) {
     String commaSeparatedFields = joinStringFields(",", allFields, configuration.quoteCharacter());
-    String commaSeparatedPKFields = String.join(", ", primaryKeyFields);
+    String commaSeparatedPKFields =
+        joinStringFields(", ", primaryKeyFields, configuration.quoteCharacter());
     return String.format(
         PARTITION_BY_PK_AND_SORT_TEMPLATE,
         commaSeparatedFields,