[
https://issues.apache.org/jira/browse/SAMZA-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439367#comment-15439367
]
Neil Fordyce commented on SAMZA-1007:
-------------------------------------
>From a quick look at
>[GroupBySystemStreamPartitionFactory|https://github.com/apache/samza/blob/master/samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartitionFactory.java],
> config isn't passed through to GroupBySystemStreamPartition which would cause
>broadcasts inputs to be ignored.
Happy to provide a patch for this soon.
> 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)
