[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4775 ---

[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4775#discussion_r143254179 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java --- @@ -121,10 +122,1

[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-06 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4775#discussion_r143162433 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java --- @@ -121,10 +122,13

[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-06 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4775#discussion_r143149399 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java --- @@ -121,10 +122,13 @

[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-04 Thread pnowojski
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