Skip to content

Commit 3024664

Browse files
committed
PLUGIN-1513 Fixed job location for BQ Sink Pushdown Jobs
1 parent 060a402 commit 3024664

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ private SQLWriteResult writeInternal(SQLWriteRequest writeRequest,
223223
// Create a job ID so that we can safely retry.
224224
JobId bqJobId = JobId.newBuilder()
225225
.setJob(jobId)
226-
.setLocation(sqlEngineConfig.getLocation())
226+
.setLocation(srcDataset.getLocation())
227227
.setProject(sqlEngineConfig.getProject())
228228
.build();
229229
Job queryJob = bigQuery.create(JobInfo.newBuilder(queryConfig).setJobId(bqJobId).build());

0 commit comments

Comments
 (0)