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

pwason pushed a commit to branch release-0.14.0
in repository https://gitbox.apache.org/repos/asf/hudi.git

commit 4af3b7eefa67822443d013ac4632089e02b97303
Author: Jinpeng <[email protected]>
AuthorDate: Sun Sep 10 21:12:28 2023 -0400

    [HUDI-6831] Add back missing project_id to query statement in 
BigQuerySyncTool (#9650)
    
    Co-authored-by: jp0317 <[email protected]>
---
 .../java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java
 
b/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java
index 17990e76929..8c8372a992a 100644
--- 
a/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java
+++ 
b/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java
@@ -94,8 +94,9 @@ public class HoodieBigQuerySyncClient extends 
HoodieSyncClient {
       }
       String query =
           String.format(
-              "CREATE EXTERNAL TABLE `%s.%s` %s OPTIONS (%s "
+              "CREATE EXTERNAL TABLE `%s.%s.%s` %s OPTIONS (%s "
               + "uris=[\"%s\"], format=\"PARQUET\", 
file_set_spec_type=\"NEW_LINE_DELIMITED_MANIFEST\")",
+              projectId,
               datasetName,
               tableName,
               withClauses,

Reply via email to