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());