[ https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705688#comment-14705688 ]
Yan Fang commented on SAMZA-676: -------------------------------- [~navina], thanks for the review. Fixed all issues you mentioned in the RB except the "isBroadcast" flag. For the "isBroadcast" flag, I tried to add it in the SystemStreamPartition, but since this is an API change, it is not trivial: all the system code is using the "system.stream.partition" format, which does not contain the "isBroadcast" information, we will have to change all the places which use this format; it is also possible that users are using this format to pass around the SystemStreamPartition, we may break their code if we change to something like "system.stream.partition.isBroadcast". So I decide not to make this change so far. What do you think? > Implement Broadcast Stream > -------------------------- > > Key: SAMZA-676 > URL: https://issues.apache.org/jira/browse/SAMZA-676 > Project: Samza > Issue Type: Improvement > Components: container > Reporter: Yan Fang > Assignee: Yan Fang > Attachments: BroadcastStreamDesign.md, BroadcastStreamDesign.pdf, > BroadcastStreamDesign_1.md, BroadcastStreamDesign_1.pdf, SAMZA-676.2.patch, > SAMZA-676.3.patch, SAMZA-676.4.patch > > > There are a lot of discussion in SAMZA-353 about assigning the same SSP to > multiple taskNames. This ticket is a subset of the discussion. Only focus on > the broadcast stream implementation. > The goal is to assign one SSP to all the taskNames. -- This message was sent by Atlassian JIRA (v6.3.4#6332)