GitHub user shanthoosh opened a pull request:
https://github.com/apache/samza/pull/68
SAMZA-1100: Exception when using a stream as both bootstrap and broadcast.
When a task input stream is used as both broadcast and bootstrap stream in
a samza job, Bootstrappingchooser marks the stream as bootstrapped when a
single task finishes consuming all the SystemStreamPartitions(This happens when
all the starting offset for each partition in the input stream is of type
upcoming). This patch fixes this, by marking a stream as bootstrapped, only
when all the systemStreamPartitions in a input stream is consumed by all the
expected tasks.
More details here : https://issues.apache.org/jira/browse/SAMZA-1100
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shanthoosh/samza master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/68.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #68
----
commit 3a0c0c9315832d2a5d1af82ac35be2c10b5f37ae
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Date: 2017-02-27T18:45:42Z
SAMZA-1100: Exception when using a stream as both bootstrap and broadcast.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
