Address serialization issue

apache · Dec 6, 2016 · 1ca49af · 1ca49af
1 parent 2d05f10
commit 1ca49af
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java b/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
@@ -661,7 +661,9 @@ public PCollection<TableRow> apply(PBegin input) {
               .setTableId(queryTempTableId);
 
           source = BigQueryQuerySource.create(
-              jobIdToken, query, StaticValueProvider.of(queryTempTableRef),
+              jobIdToken, query, NestedValueProvider.of(
+                  StaticValueProvider.of(
+                      toJsonString(queryTempTableRef)), new JsonTableRefToTableRef()),
               flattenResults, useLegacySql, extractDestinationDir, bqServices);
         } else {
           ValueProvider<TableReference> inputTable = getTableWithDefaultProject(bqOptions);