From 5625ffbf5ab9cfee4debbc38afc6a1fe5c69c892 Mon Sep 17 00:00:00 2001
From: Dan Halperin <dhalperi@google.com>
Date: Mon, 6 Feb 2017 14:48:43 -0800
Subject: [PATCH] fixups

---
 .../main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java
index 3472a8afed..a6d9871287 100644
--- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java
+++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java
@@ -1158,6 +1158,7 @@ private void executeQuery(
           .setAllowLargeResults(true)
           .setCreateDisposition("CREATE_IF_NEEDED")
           .setDestinationTable(destinationTable)
+          .setPriority("BATCH")
           .setWriteDisposition("WRITE_EMPTY");
 
       jobService.startQueryJob(jobRef, queryConfig);
@@ -1172,7 +1173,6 @@ private JobConfigurationQuery createBasicQueryConfig() {
       // then the similar code in BigQueryTableRowIterator#fromQuery should be updated.
       return new JobConfigurationQuery()
           .setFlattenResults(flattenResults)
-          .setPriority("BATCH")
           .setQuery(query.get())
           .setUseLegacySql(useLegacySql);
     }