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,