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

danny0405 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 e265105799e [HUDI-6831] Add back missing project_id to query statement 
in BigQuerySyncTool (#9650)
e265105799e is described below

commit e265105799eeee0cd871e88e9e7d52eb1cfb90f2
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