GitHub user navina opened a pull request:
https://github.com/apache/samza/pull/112
Samza-1187 : TestZkProcessorLatch tests share state causing transient
failures in CI builds
* Removed testSingleCountdown - didn't understand what was being tested
* The timeout behavior for ZkPro
Thank you Jagadish.
Regarding leader selection, we exposed some additional metrics that are
supposed to tell us which broker is leader for each partition and we confirmed
your theory, Samza consumer if fully aware who is the current leader.
Entire logs are pretty big so here are some parts inst
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/92
---
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 enable
GitHub user prateekm opened a pull request:
https://github.com/apache/samza/pull/113
SAMZA-1191: Fixed flaky test: TestExponentialSleepStrategy
testThreadInterruptInRetryLoop
It's possible that the interruptee thread (see `#interruptedThread`) gets
pre-empted before it has a chance
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/113
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/97
---
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 enable
