Fixed issue with BigQuery jobs for update/upsert failing

fernst · fernst · commit 8d1ac5062fcc · 2022-03-25T16:25:46.000-04:00
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
@@ -388,7 +388,6 @@ protected QueryJobConfiguration.Builder getUpdateUpsertQueryJobBuilder(TableId s
 
     return QueryJobConfiguration.newBuilder(query)
       .setPriority(sqlEngineConfig.getJobPriority())
-      .setCreateDisposition(JobInfo.CreateDisposition.CREATE_NEVER)
       .setLabels(BigQuerySQLEngineUtils.getJobTags("copy"));
   }
 

Original file line number	Diff line number	Diff line change
`@@ -388,7 +388,6 @@ protected QueryJobConfiguration.Builder getUpdateUpsertQueryJobBuilder(TableId s`
`388`	`388`
`389`	`389`	`return QueryJobConfiguration.newBuilder(query)`
`390`	`390`	`.setPriority(sqlEngineConfig.getJobPriority())`
`391`		`- .setCreateDisposition(JobInfo.CreateDisposition.CREATE_NEVER)`
`392`	`391`	`.setLabels(BigQuerySQLEngineUtils.getJobTags("copy"));`
`393`	`392`	`}`
`394`	`393`