[GitHub] samza pull request #456: SAMZA-1627: Watermark broadcast enhancements
GitHub user xinyuiscool opened a pull request: https://github.com/apache/samza/pull/456 SAMZA-1627: Watermark broadcast enhancements Currently each upstream task needs to broadcast to every single partition of intermediate streams in order to aggregate watermarks in the consumers. A
[GitHub] samza pull request #450: ScheduleAfterDebounceTime should catch all Throwabl...
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/450 ---
[GitHub] samza pull request #214: SAMZA-1293: Enable partition expansion of input str...
Github user lindong28 closed the pull request at: https://github.com/apache/samza/pull/214 ---