[hudi] branch master updated: [HUDI-6870] Pass project ID to BigQuery job (#9730)

[danny0405]

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 59c4dc33e6f [HUDI-6870] Pass project ID to BigQuery job (#9730)
59c4dc33e6f is described below

commit 59c4dc33e6f280e2730683c7e385b8fc512e950d
Author: emkornfield <emkornfi...@gmail.com>
AuthorDate: Sat Sep 16 19:11:46 2023 -0700

    [HUDI-6870] Pass project ID to BigQuery job (#9730)
---
 .../java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 fa32f931049..a5462b5669e 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
@@ -49,7 +49,6 @@ import org.slf4j.LoggerFactory;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
-import java.util.UUID;
 import java.util.stream.Collectors;
 
 import static 
org.apache.hudi.gcp.bigquery.BigQuerySyncConfig.BIGQUERY_SYNC_DATASET_LOCATION;
@@ -118,7 +117,7 @@ public class HoodieBigQuerySyncClient extends 
HoodieSyncClient {
       QueryJobConfiguration queryConfig = 
QueryJobConfiguration.newBuilder(query)
           .setUseLegacySql(false)
           .build();
-      JobId jobId = JobId.of(UUID.randomUUID().toString());
+      JobId jobId = 
JobId.newBuilder().setProject(projectId).setRandomJob().build();
       Job queryJob = 
bigquery.create(JobInfo.newBuilder(queryConfig).setJobId(jobId).build());
 
       queryJob = queryJob.waitFor();