[hudi] branch master updated: [MINOR] Fixing failing tests with BQ sync tests (#9684)

[sivabalan]

This is an automated email from the ASF dual-hosted git repository.

sivabalan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new d725d79dae3 [MINOR] Fixing failing tests with BQ sync tests (#9684)
d725d79dae3 is described below

commit d725d79dae35d32b177ecdb02f9c7cf679dc4e57
Author: Sivabalan Narayanan <n.siv...@gmail.com>
AuthorDate: Mon Sep 11 17:57:23 2023 -0400

    [MINOR] Fixing failing tests with BQ sync tests (#9684)
---
 .../apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java
 
b/hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java
index df7e6a9f31e..189f3efa222 100644
--- 
a/hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java
+++ 
b/hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java
@@ -94,8 +94,9 @@ public class TestHoodieBigQuerySyncClient {
 
     QueryJobConfiguration configuration = 
jobInfoCaptor.getValue().getConfiguration();
     assertEquals(configuration.getQuery(),
-        String.format("CREATE EXTERNAL TABLE `%s.%s` ( field STRING ) WITH 
PARTITION COLUMNS OPTIONS (enable_list_inference=true, 
hive_partition_uri_prefix=\"%s\", uris=[\"%s\"], format=\"PARQUET\", "
-            + "file_set_spec_type=\"NEW_LINE_DELIMITED_MANIFEST\")", 
TEST_DATASET, TEST_TABLE, SOURCE_PREFIX, MANIFEST_FILE_URI));
+        String.format("CREATE EXTERNAL TABLE `%s.%s.%s` ( field STRING ) WITH 
PARTITION COLUMNS OPTIONS (enable_list_inference=true, "
+            + "hive_partition_uri_prefix=\"%s\", uris=[\"%s\"], 
format=\"PARQUET\", "
+            + "file_set_spec_type=\"NEW_LINE_DELIMITED_MANIFEST\")", 
PROJECT_ID, TEST_DATASET, TEST_TABLE, SOURCE_PREFIX, MANIFEST_FILE_URI));
   }
 
   @Test
@@ -113,7 +114,7 @@ public class TestHoodieBigQuerySyncClient {
 
     QueryJobConfiguration configuration = 
jobInfoCaptor.getValue().getConfiguration();
     assertEquals(configuration.getQuery(),
-        String.format("CREATE EXTERNAL TABLE `%s.%s` ( field STRING ) OPTIONS 
(enable_list_inference=true, uris=[\"%s\"], format=\"PARQUET\", "
-            + "file_set_spec_type=\"NEW_LINE_DELIMITED_MANIFEST\")", 
TEST_DATASET, TEST_TABLE, MANIFEST_FILE_URI));
+        String.format("CREATE EXTERNAL TABLE `%s.%s.%s` ( field STRING ) 
OPTIONS (enable_list_inference=true, uris=[\"%s\"], format=\"PARQUET\", "
+            + "file_set_spec_type=\"NEW_LINE_DELIMITED_MANIFEST\")", 
PROJECT_ID, TEST_DATASET, TEST_TABLE, MANIFEST_FILE_URI));
   }
 }