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 <[email protected]> Authored: Tue Aug 1 16:18:15 2017 -0700 Committer: Robert Bradshaw <[email protected]> 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
