[GitHub] samza pull request #829: SAMZA-2012: Add API for wiring an external context ...

2018-12-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/829 ---

[GitHub] samza pull request #846: SAMZA-2019: for 1 partition broadcast topic generat...

2018-12-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/846 ---

[GitHub] samza pull request #846: SAMZA-2019: for 1 partition broadcast topic generat...

2018-12-05 Thread sborya
GitHub user sborya opened a pull request: https://github.com/apache/samza/pull/846 SAMZA-2019: for 1 partition broadcast topic generate topic#0 config + address few review comments You can merge this pull request into a Git repository by running: $ git pull https://github.com/s

[GitHub] samza pull request #837: SAMZA-2019: add Is broadcast per stream config

2018-12-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/837 ---

[GitHub] samza pull request #790: SAMZA-1973: Unify the TaskNameGrouper interface for...

2018-12-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/790 ---

[GitHub] samza pull request #622: [EXPERIMENTAL] : Handle Repartitioning of Streams

2018-12-05 Thread MayureshGharat
Github user MayureshGharat closed the pull request at: https://github.com/apache/samza/pull/622 ---

[GitHub] samza pull request #845: Supports environment variables for SqlExecutors.

2018-12-05 Thread weiqingy
GitHub user weiqingy opened a pull request: https://github.com/apache/samza/pull/845 Supports environment variables for SqlExecutors. ## What changes were proposed in this pull request? 1. User can now set environment variables for the shell itself and for any SqlExecutor, by e

[GitHub] samza pull request #844: SAMZA-1835: Consolidate all processorId generation ...

2018-12-05 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/844 SAMZA-1835: Consolidate all processorId generation code. Currently, the processorId creation function createProcessorId() is repeated in three different implementation of `JobCoordinator` viz `Zk