Fix due to GBKO name change.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6f5888e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a6f5888e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a6f5888e Branch: refs/heads/release-2.0.0 Commit: a6f5888e42ef34eacfe6384c0de9df9371ae968c Parents: e12cf0d Author: Robert Bradshaw <[email protected]> Authored: Thu May 11 15:47:54 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Thu May 11 16:20:37 2017 -0700 ---------------------------------------------------------------------- .../apache_beam/runners/portability/maptask_executor_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a6f5888e/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py b/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py index 077871e..ddfc4cc 100644 --- a/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py +++ b/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py @@ -243,7 +243,7 @@ class MapTaskExecutorRunner(PipelineRunner): (label, write_sideinput_op)) return output_buffer - def run_GroupByKeyOnly(self, transform_node): + def run__GroupByKeyOnly(self, transform_node): map_task_index, producer_index, output_index = self.outputs[ transform_node.inputs[0]] grouped_element_coder = self._get_coder(transform_node.outputs[None],
