[BEAM-11185] Aggregate Functions - CombineGlobally and CombinePerKey not working for side inputs (either for Singleton, AsIter, AsDict

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.24.0
• Component/s: examples-python
• Environment: OS: Mac Catalina
• Assignee: Unassigned
• Reporter: aravindh venkatesh
• Created: 03/Nov/20 18:59
• Updated: 04/Jun/22 18:18

Description

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)