You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "aravindh venkatesh (Jira)" <ji...@apache.org> on 2020/11/03 19:00:00 UTC
[jira] [Created] (BEAM-11185) Aggregate Functions - CombineGlobally
and CombinePerKey not working for side inputs (either for Singleton,
AsIter, AsDict
aravindh venkatesh created BEAM-11185:
-----------------------------------------
Summary: Aggregate Functions - CombineGlobally and CombinePerKey not working for side inputs (either for Singleton, AsIter, AsDict
Key: BEAM-11185
URL: https://issues.apache.org/jira/browse/BEAM-11185
Project: Beam
Issue Type: Bug
Components: examples-python
Affects Versions: 2.24.0
Environment: OS: Mac Catalina
Reporter: aravindh venkatesh
Hi,
Python examples for Aggregate transformer - CombineGlobally and CombiePerKey doesn't work for side inputs (singleton, iter and dict). Even when used with custom class inheriting beam.CombineFn it fails.
Third combine transformer - i.e., CombineValues is working fine without any issue.
Steps to recreate problem:
Python version 3.7.3
Apache beam = 2.24.0 (installed with gcp data flow components)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)