[FLINK-7739][kafka-tests] Throttle down data producing thread

This closes apache#4751.
amuraru · Oct 30, 2017 · 152f6c9 · 152f6c9
1 parent 185c807
commit 152f6c9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java b/...base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
@@ -139,6 +139,9 @@ public void run(SourceContext<Tuple2<Long, String>> ctx) throws Exception {
  while (running) {
  ctx.collect(new Tuple2<Long, String>(cnt, "kafka-" + cnt));
  cnt++;
+ if (cnt % 100 == 0) {
+ Thread.sleep(1);
+ }
  }
  }