Merge pull request apache#10109 [BEAM-8657] Combiner lifting fix for …

…bundle-based direct runner.
mransley · Nov 15, 2019 · 4ee06ce · 4ee06ce
2 parents 2f00613 + d3f8192
commit 4ee06ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py
@@ -187,7 +187,7 @@ def _get_transform_overrides(pipeline_options):
  class CombinePerKeyOverride(PTransformOverride):
  def matches(self, applied_ptransform):
  if isinstance(applied_ptransform.transform, CombinePerKey):
- return True
+ return applied_ptransform.inputs[0].windowing.is_default()
 
  def get_replacement_transform(self, transform):
  # TODO: Move imports to top. Pipeline <-> Runner dependency cause problems