[BEAM-9830] Flink and Samza pipeline options are incompatible

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-flink, runner-samza
• Assignee: Unassigned
• Reporter: Kyle Weaver
• Created: 27/Apr/20 17:12
• Updated: 04/Jun/22 15:37

Description

When both the Flink and Samza runners are included in the same application, an exception occurs because they define getMaxBundleSize with different types (long and Long):
Caused by: java.lang.IllegalArgumentException: methods with same signature getMaxBundleSize() but incompatible return types: long and others

Originally reported here: https://stackoverflow.com/questions/61441333/conflict-with-runner-dependencies-in-beam