Skip to content

Commit 5625ffb

Browse files
committed
fixups
1 parent 502f99f commit 5625ffb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1158,6 +1158,7 @@ private void executeQuery(
11581158
.setAllowLargeResults(true)
11591159
.setCreateDisposition("CREATE_IF_NEEDED")
11601160
.setDestinationTable(destinationTable)
1161+
.setPriority("BATCH")
11611162
.setWriteDisposition("WRITE_EMPTY");
11621163

11631164
jobService.startQueryJob(jobRef, queryConfig);
@@ -1172,7 +1173,6 @@ private JobConfigurationQuery createBasicQueryConfig() {
11721173
// then the similar code in BigQueryTableRowIterator#fromQuery should be updated.
11731174
return new JobConfigurationQuery()
11741175
.setFlattenResults(flattenResults)
1175-
.setPriority("BATCH")
11761176
.setQuery(query.get())
11771177
.setUseLegacySql(useLegacySql);
11781178
}

0 commit comments

Comments
 (0)