[beam] branch master updated: Properly propagate environment in combiner lifting.

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new b0ec216  Properly propagate environment in combiner lifting.
     new fea721a  Merge pull request #7562 Combiner Lifting Environment
b0ec216 is described below

commit b0ec216dcabfd3bd70e3364fb13185021b0fd395
Author: Robert Bradshaw <ro...@google.com>
AuthorDate: Fri Jan 18 15:05:42 2019 +0100

    Properly propagate environment in combiner lifting.
---
 .../python/apache_beam/runners/portability/fn_api_runner_transforms.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py b/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py
index d36db6f..8152c0c 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py
@@ -471,7 +471,8 @@ def lift_combiners(stages, context):
             [transform],
             downstream_side_inputs=base_stage.downstream_side_inputs,
             must_follow=base_stage.must_follow,
-            parent=base_stage.name)
+            parent=base_stage.name,
+            environment=base_stage.environment)
 
       yield make_stage(
           stage,