(beam) branch master updated: Priority to BigQueryProject for executeExtract (#36694)

[yhu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 9516397165c Priority to BigQueryProject for executeExtract (#36694)
9516397165c is described below

commit 9516397165c4ff68e4d17e369e3a00bc95bc902c
Author: Tanu Sharma <53229637+tanusharma2...@users.noreply.github.com>
AuthorDate: Sat Nov 8 21:19:14 2025 +0530

    Priority to BigQueryProject for executeExtract (#36694)
    
    * Priority to BigQueryProject
    
    * Spotless Apply
---
 .../org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java
index d2aed44d9f4..40cebca1770 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java
@@ -133,12 +133,16 @@ abstract class BigQuerySourceBase<T> extends 
BoundedSource<T> {
       String bqLocation =
           BigQueryHelpers.getDatasetLocation(
               datasetService, tableToExtract.getProjectId(), 
tableToExtract.getDatasetId());
+      String bqProjectId =
+          bqOptions.getBigQueryProject() != null
+              ? bqOptions.getBigQueryProject()
+              : bqOptions.getProject();
       List<ResourceId> tempFiles =
           executeExtract(
               extractJobId,
               tableToExtract,
               jobService,
-              bqOptions.getProject(),
+              bqProjectId,
               extractDestinationDir,
               bqLocation,
               useAvroLogicalTypes);