[GitHub] samza pull request #362: Create changelog streams in Leader(ZkJobCoordinator...

2017-11-15 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/362 Create changelog streams in Leader(ZkJobCoordinator) for stateful operators. Verified with a test standalone job. Will add integration test for this as a part of fixing and reenabling standalone i

[GitHub] samza pull request #361: SAMZA-1504: Allow user to register container-level ...

2017-11-15 Thread xinyuiscool
GitHub user xinyuiscool opened a pull request: https://github.com/apache/samza/pull/361 SAMZA-1504: Allow user to register container-level metrics This change allows user to register the metrics on the per-container basis. Tested in beam runner and works as expected.

[GitHub] samza pull request #358: SAMZA-1495: Set intermediate streams as higher prio...

2017-11-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/358 ---

[GitHub] samza pull request #359: SAMZA-1501: Validate operator IDs so that they don'...

2017-11-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/359 ---