Neil Fordyce created SAMZA-1007:
-----------------------------------
Summary: Broadcast streams incompatible with
GroupBySystemStreamPartitionFactory
Key: SAMZA-1007
URL: https://issues.apache.org/jira/browse/SAMZA-1007
Project: Samza
Issue Type: Bug
Reporter: Neil Fordyce
Priority: Minor
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.
{code}
job.systemstreampartition.grouper.factory=org.apache.samza.container.grouper.stream.GroupBySystemStreamPartitionFactory
task.broadcast.inputs=kafka.broadcast-input-topic#0
task.inputs=kafka.input-topic
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
