[
https://issues.apache.org/jira/browse/SAMZA-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neil Fordyce updated SAMZA-1007:
--------------------------------
Attachment: SAMZA-1007-0.patch
> Broadcast streams incompatible with GroupBySystemStreamPartitionFactory
> -----------------------------------------------------------------------
>
> Key: SAMZA-1007
> URL: https://issues.apache.org/jira/browse/SAMZA-1007
> Project: Samza
> Issue Type: Bug
> Affects Versions: 0.10.0, 0.10.1
> Reporter: Neil Fordyce
> Priority: Minor
> Fix For: 0.11.0
>
> Attachments: SAMZA-1007-0.patch
>
>
> 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)
