[FLINK-11826] Ignore flaky testRateLimitedConsumer

blacktooth · Mar 5, 2019 · 56afa2e · 56afa2e
1 parent 11a8234
commit 56afa2e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...or-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java b/...or-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
@@ -34,6 +34,7 @@
 import org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import java.io.ByteArrayInputStream;
@@ -166,6 +167,7 @@ public void testAutoOffsetRetrievalAndCommitToKafka() throws Exception {
 	 * a desired rate of 3 bytes / second. Based on the execution time, the test asserts that this rate was not surpassed.
 	 * If no rate limiter is set on the consumer, the test should fail.
 	 */
+	@Ignore
 	@Test(timeout = 60000)
 	public void testRateLimitedConsumer() throws Exception {
 		final String testTopic = "testRateLimitedConsumer";