beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [16/19] beam git commit: Fix due to GBKO name change.
Date Fri, 12 May 2017 00:12:10 GMT
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 <robertwb@gmail.com>
Authored: Thu May 11 15:47:54 2017 -0700
Committer: Ahmet Altay <altay@google.com>
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],


Mime
View raw message