[jira] [Created] (SAMZA-1007) Broadcast streams incompatible with GroupBySystemStreamPartitionFactory

["Neil Fordyce (JIRA)" <ji...@apache.org>]

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)