[hotfix] Ignore failing test reported in FLINK-22559

bbejeck · May 7, 2021 · aca4328 · aca4328
1 parent 8f3d483
commit aca4328
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...c/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java b/...c/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java
@@ -23,6 +23,7 @@
 import org.apache.flink.table.utils.LegacyRowResource;
 import org.apache.flink.types.Row;
 
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -197,6 +198,7 @@ public void testSourceSinkWithKeyAndPartialValue() throws Exception {
  }
 
  @Test
+ @Ignore // FLINK-22559
  public void testKafkaSourceSinkWithKeyAndFullValue() throws Exception {
  // we always use a different topic name for each parameterized topic,
  // in order to make sure the topic can be created.