[Improve] kafka avro e2e

liunaijie · Dec 28, 2023 · 886a416 · 886a416
1 parent 2b93dfd
commit 886a416
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java b/...e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
@@ -305,7 +305,7 @@ public void testFakeSourceToKafkaAvroFormat(TestContainer container)
     }
 
     @TestTemplate
-    @DisabledOnContainer(TestContainerId.SPARK_2_4)
+    @DisabledOnContainer(value = {TestContainerId.FLINK_1_13, TestContainerId.SPARK_2_4})
     public void testKafkaAvroToAssert(TestContainer container)
             throws IOException, InterruptedException {
         DefaultSeaTunnelRowSerializer serializer =