GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4775
[FLINK-7739] Fix KafkaXXITCase tests stability
## What is the purpose of the change
This change fixes Kafka*ITCase tests stability. Main fix is excluding
`netty` dependency from zookeeper. Other two are probably just cosmetic changes.
For more info please look into individual commit messages.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pnowojski/flink kafka-test2
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4775.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 #4775
----
commit c7cc24d062aa233d86b68b7438c9a4e717003393
Author: Piotr Nowojski <[email protected]>
Date: 2017-09-29T16:23:29Z
[FLINK-7739][kafka-tests] Set shorter heartbeats intervals
Default pause value of 60seconds is too large (tests would timeout before
akka react)
commit 1677791f10153b9f7ecd552eac148d6ae3d056f1
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-04T11:48:11Z
[FLINK-7739][kafka-tests] Set restart delay to non zero
Give TaskManagers some time to clean up before restaring a job.
commit 937c3fb388d9d7104b6336f59c3674bb70bfbf50
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-04T14:50:57Z
[FLINK-7739] Exclude netty dependency from zookeeper
Zookeeper was pulling in conflicting Netty version. Conflict was
extremly subtle - TaskManager in kafka tests was deadlocking in some
rare corner cases.
----
---
