[SAMZA-1007] Broadcast streams incompatible with GroupBySystemStreamPartitionFactory

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.10.0, 0.10.1
• Fix Version/s: 0.11.0
• Assignee: Neil Fordyce
• Reporter: Neil Fordyce
• Created: 25/Aug/16 13:25
• Updated: 11/Sep/16 00:36
• Resolved: 11/Sep/16 00:36

Description

Jobs using broadcast streams in combination with GroupBySystemStreamPartitionFactory do not assign broadcast inputs to any tasks.

E.g. with the following config extract, the task consuming input-topic would not consume broadcast-input-topic.

job.systemstreampartition.grouper.factory=org.apache.samza.container.grouper.stream.GroupBySystemStreamPartitionFactory
task.broadcast.inputs=kafka.broadcast-input-topic#0
task.inputs=kafka.input-topic