[flink] branch master updated: [FLINK-11826] Ignore flaky testRateLimitedConsumer

[thw]

This is an automated email from the ASF dual-hosted git repository.

thw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 56afa2e  [FLINK-11826] Ignore flaky testRateLimitedConsumer
56afa2e is described below

commit 56afa2e32a841922417e4ed02282d96c430875c2
Author: Thomas Weise <t...@apache.org>
AuthorDate: Tue Mar 5 12:37:09 2019 -0800

    [FLINK-11826] Ignore flaky testRateLimitedConsumer
---
 .../java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
 
b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
index cd73872..5a4e775 100644
--- 
a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
+++ 
b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
@@ -34,6 +34,7 @@ import 
org.apache.flink.streaming.api.functions.source.SourceFunction;
 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 class Kafka09ITCase extends KafkaConsumerTestBase {
         * 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";