Revert "[FLINK-21556] Temporarily disable StreamingKafkaITCase"

This reverts commit 6f8f307.
kination · Mar 31, 2021 · 08c57d4 · 08c57d4
1 parent 2d76d17
commit 08c57d4
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java b/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
@@ -31,7 +31,6 @@
 import org.apache.flink.util.TestLogger;
 
 import org.junit.Assert;
-import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
@@ -49,7 +48,6 @@
 import java.util.stream.Collectors;
 
 /** End-to-end test for the kafka connectors. */
-@Ignore // disabled because of stalling
 @RunWith(Parameterized.class)
 @Category(value = {TravisGroup1.class, PreCommit.class, FailsOnJava11.class})
 public class StreamingKafkaITCase extends TestLogger {