Repository: beam Updated Branches: refs/heads/master 37e0b437e -> 07e5536bc
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/fc3e28de Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fc3e28de Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fc3e28de Branch: refs/heads/master Commit: fc3e28de37acc9de597518cf9fe793d1ddebcf2a Parents: 37e0b43 Author: Robert Bradshaw <[email protected]> Authored: Thu May 11 15:47:54 2017 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Thu May 11 15:50:31 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/fc3e28de/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],
