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/05/11 22:54:34 UTC
[1/2] beam git commit: Fix due to GBKO name change.
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 <ro...@gmail.com>
Authored: Thu May 11 15:47:54 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
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],
[2/2] beam git commit: Closes #3101
Posted by ro...@apache.org.
Closes #3101
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/07e5536b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/07e5536b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/07e5536b
Branch: refs/heads/master
Commit: 07e5536bc128a324e213eec1a6bd97beb950dcc6
Parents: 37e0b43 fc3e28d
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Thu May 11 15:50:35 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Thu May 11 15:50:35 2017 -0700
----------------------------------------------------------------------
.../apache_beam/runners/portability/maptask_executor_runner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------