GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1172
Harden Kafka Tests
- Reduces the fork count for Kafka tests to 1
- Retries the ConcurrentProduceConsumer test in case of
"NotLeaderForPartitionException".
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink kafka
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1172.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1172
----
commit 44fe370d2233f37664117846e18bb7ebf4c3c9fe
Author: Stephan Ewen <[email protected]>
Date: 2015-09-23T10:18:16Z
[FLINK-2744] [kafka connector] Reduce number of concurrent test forks to
improce test stability on CI environment.
commit 6ae1e9b5c87135ee1c6945e1f704f1d12e7eb405
Author: Stephan Ewen <[email protected]>
Date: 2015-09-23T11:31:13Z
[tests] Improve Kafka concurrent produce/consumer test by allowing retries
when connecting to non-leader broker.
----
---
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 enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
