You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/08/03 03:44:32 UTC
[1/2] beam git commit: Fix typo in dataflow_runner.
Repository: beam
Updated Branches:
refs/heads/master 8ac796c5e -> 520a51b4f
Fix typo in dataflow_runner.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9cbc0d3b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9cbc0d3b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9cbc0d3b
Branch: refs/heads/master
Commit: 9cbc0d3b7d9c23acafd101f1e9093914fb792f39
Parents: 8ac796c
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Tue Aug 1 16:18:15 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Wed Aug 2 20:44:15 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/9cbc0d3b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index d653e91..87785a2 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -592,7 +592,7 @@ class DataflowRunner(PipelineRunner):
# Note that the accumulator must not have a WindowedValue encoding, while
# the output of this step does in fact have a WindowedValue encoding.
accumulator_encoding = self._get_cloud_encoding(
- transform_node.fn.get_accumulator_coder())
+ transform_node.transform.fn.get_accumulator_coder())
output_encoding = self._get_encoded_output_coder(transform_node)
step.encoding = output_encoding
[2/2] beam git commit: Closes #3671
Posted by ro...@apache.org.
Closes #3671
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/520a51b4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/520a51b4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/520a51b4
Branch: refs/heads/master
Commit: 520a51b4f54bebf1534a5a8c3cb78d196ba8e1f8
Parents: 8ac796c 9cbc0d3
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Wed Aug 2 20:44:16 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Wed Aug 2 20:44:16 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------