Update the BQ export flat from Json to Avro

apache · Dec 14, 2016 · 0a558c7 · 0a558c7
1 parent e383c77
commit 0a558c7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow_runner.py
@@ -520,7 +520,7 @@ def run_Read(self, transform_node):
     elif transform.source.format == 'text':
       step.add_property(PropertyNames.FILE_PATTERN, transform.source.path)
     elif transform.source.format == 'bigquery':
-      step.add_property(PropertyNames.BIGQUERY_EXPORT_FORMAT, 'FORMAT_JSON')
+      step.add_property(PropertyNames.BIGQUERY_EXPORT_FORMAT, 'FORMAT_AVRO')
       # TODO(silviuc): Add table validation if transform.source.validate.
       if transform.source.table_reference is not None:
         step.add_property(PropertyNames.BIGQUERY_DATASET,