[GitHub] samza pull request #341: Checkpoint manager implementation with Azure Table

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

[GitHub] samza pull request #352: Added tests, make eventData creation extensible

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

[GitHub] samza pull request #352: Added tests, make eventData creation extensible

2017-11-07 Thread dxichen
GitHub user dxichen opened a pull request: https://github.com/apache/samza/pull/352 Added tests, make eventData creation extensible @vjagadish1989 Required for internal custom eventData creation You can merge this pull request into a Git repository by running: $ git pull https:

[GitHub] samza pull request #351: SAMZA-1482: Restart or fail Samza jobs in YARN when...

2017-11-07 Thread nickpan47
GitHub user nickpan47 opened a pull request: https://github.com/apache/samza/pull/351 SAMZA-1482: Restart or fail Samza jobs in YARN when detecting changes… … in input topic partitions Some high-lights of the changes: # always instantiating StreamPartitionCountMonito

[GitHub] samza pull request #345: SAMZA-1477: Fix issues found by BEAM tests

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

Re: Samza 13.1 and Kafka 1.0

2017-11-07 Thread Ignacio Solis
XiaoChuan, if you want to do some testing with Kafka 1.0 and report your findings you are highly encouraged :-). On Tue, Nov 7, 2017 at 9:56 AM, Yi Pan wrote: > Hi, XiaoChuan, > > Sorry to reply late. Samza 13.1 is built w/ Kafka 0.10.1.1. We have not > test against Kafka broker 1.0 yet. We usual

Re: Samza 13.1 and Kafka 1.0

2017-11-07 Thread Yi Pan
Hi, XiaoChuan, Sorry to reply late. Samza 13.1 is built w/ Kafka 0.10.1.1. We have not test against Kafka broker 1.0 yet. We usually release Samza with the Kafka version that is running as a stable one in LinkedIn. If you have specific feature requirements that is only in Kafka 1.0, please let us