Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5669#discussion_r173437603 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java --- @@ -81,12 +81,6 @@ public void testCancelingEmptyTopic() throws Exception { public void testCancelingFullTopic() throws Exception { runCancelingOnFullInputTest(); } - --- End diff -- Why are those removed?
---