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 d2aed44d9f48..40cebca17706 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 @@ protected ExtractResult extractFiles(PipelineOptions options) throws Exception {
       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);