beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [1/2] incubator-beam git commit: Rollback the default format to json
Date Tue, 06 Dec 2016 02:04:55 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/python-sdk eb98d636e -> e73bdb5c2


Rollback the default format to json


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b7748cca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b7748cca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b7748cca

Branch: refs/heads/python-sdk
Commit: b7748cca9c2da97337ae94c18c8b8b70e59ed655
Parents: eb98d63
Author: Sourabh Bajaj <sourabhbajaj@google.com>
Authored: Mon Dec 5 18:03:43 2016 -0800
Committer: Sourabh Bajaj <sourabhbajaj@google.com>
Committed: Mon Dec 5 18:03:43 2016 -0800

----------------------------------------------------------------------
 sdks/python/apache_beam/runners/dataflow_runner.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b7748cca/sdks/python/apache_beam/runners/dataflow_runner.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow_runner.py
index a3f7d94..8b953b0 100644
--- a/sdks/python/apache_beam/runners/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow_runner.py
@@ -520,7 +520,7 @@ class DataflowPipelineRunner(PipelineRunner):
     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_AVRO')
+      step.add_property(PropertyNames.BIGQUERY_EXPORT_FORMAT, 'FORMAT_JSON')
       # TODO(silviuc): Add table validation if transform.source.validate.
       if transform.source.table_reference is not None:
         step.add_property(PropertyNames.BIGQUERY_DATASET,


Mime
View raw message