Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5599 I watched the code and think it is very good. But the travis says ``` Results : Tests in error: FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint:333 » TestTimedOut Tests run: 42, Failures: 0, Errors: 1, Skipped: 0 18:43:11.642 [INFO] ------------------------------------------------------------------------ 18:43:11.642 [INFO] Reactor Summary: 18:43:11.642 [INFO] 18:43:11.642 [INFO] flink-hadoop-fs .................................... SUCCESS [ 16.959 s] 18:43:11.642 [INFO] flink-mapr-fs ...................................... SUCCESS [ 5.138 s] 18:43:11.642 [INFO] flink-s3-fs-hadoop ................................. SUCCESS [ 30.410 s] 18:43:11.642 [INFO] flink-s3-fs-presto ................................. SUCCESS [ 31.165 s] 18:43:11.643 [INFO] flink-hadoop-compatibility ......................... SUCCESS [01:05 min] 18:43:11.643 [INFO] flink-avro ......................................... SUCCESS [ 23.859 s] 18:43:11.643 [INFO] flink-jdbc ......................................... SUCCESS [ 8.501 s] 18:43:11.643 [INFO] flink-hbase ........................................ SUCCESS [ 46.495 s] 18:43:11.643 [INFO] flink-hcatalog ..................................... SUCCESS [ 0.871 s] 18:43:11.643 [INFO] flink-connector-kafka-base ......................... SUCCESS [ 7.658 s] 18:43:11.643 [INFO] flink-connector-kafka-0.8 .......................... SUCCESS [02:32 min] 18:43:11.643 [INFO] flink-connector-kafka-0.9 .......................... SUCCESS [02:49 min] 18:43:11.643 [INFO] flink-connector-kafka-0.10 ......................... SUCCESS [02:49 min] 18:43:11.643 [INFO] flink-connector-kafka-0.11 ......................... FAILURE [10:49 min] 18:43:11.643 [INFO] flink-connector-elasticsearch-base ................. SKIPPED 18:43:11.643 [INFO] flink-connector-elasticsearch ...................... SKIPPED 18:43:11.643 [INFO] flink-connector-elasticsearch2 ..................... SKIPPED 18:43:11.643 [INFO] flink-connector-elasticsearch5 ..................... SKIPPED 18:43:11.643 [INFO] flink-connector-rabbitmq ........................... SKIPPED 18:43:11.643 [INFO] flink-connector-twitter ............................ SKIPPED 18:43:11.643 [INFO] flink-connector-nifi ............................... SKIPPED 18:43:11.643 [INFO] flink-connector-cassandra .......................... SKIPPED 18:43:11.643 [INFO] flink-connector-filesystem ......................... SKIPPED 18:43:11.643 [INFO] flink-connector-kinesis ............................ SKIPPED 18:43:11.643 [INFO] flink-connector-wikiedits .......................... SKIPPED 18:43:11.643 [INFO] ------------------------------------------------------------------------ 18:43:11.643 [INFO] BUILD FAILURE 18:43:11.643 [INFO] ------------------------------------------------------------------------ 18:43:11.643 [INFO] Total time: 23:00 min 18:43:11.643 [INFO] Finished at: 2018-02-28T18:43:11+00:00 18:43:12.101 [INFO] Final Memory: 117M/746M ```
---