From 3024664276b3a6256a322a588d684424fb88c831 Mon Sep 17 00:00:00 2001
From: Fernando Velasquez <fevelasquez@google.com>
Date: Thu, 16 Feb 2023 14:57:40 -0500
Subject: [PATCH] PLUGIN-1513 Fixed job location for BQ Sink Pushdown Jobs

---
 .../io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java b/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java
index 6d1102ac24..2e0d1f256c 100644
--- a/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java
+++ b/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQueryWrite.java
@@ -223,7 +223,7 @@ private SQLWriteResult writeInternal(SQLWriteRequest writeRequest,
     // Create a job ID so that we can safely retry.
     JobId bqJobId = JobId.newBuilder()
       .setJob(jobId)
-      .setLocation(sqlEngineConfig.getLocation())
+      .setLocation(srcDataset.getLocation())
       .setProject(sqlEngineConfig.getProject())
       .build();
     Job queryJob = bigQuery.create(JobInfo.newBuilder(queryConfig).setJobId(bqJobId).build());