[Improve] test

liunaijie · Dec 28, 2023 · c6d6407 · c6d6407
1 parent f158cf1
commit c6d6407
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -296,7 +296,7 @@ public void testSourceKafkaStartConfig(TestContainer container)
     }
 
     @TestTemplate
-    @DisabledOnContainer(value = {TestContainerId.FLINK_1_13, TestContainerId.SPARK_2_4})
+    @DisabledOnContainer(value = {TestContainerId.SPARK_2_4})
     public void testFakeSourceToKafkaAvroFormat(TestContainer container)
             throws IOException, InterruptedException {
         Container.ExecResult execResult =
@@ -388,7 +388,7 @@ public void testFakeSourceToKafkaAvroFormat(TestContainer container)
     }
 
     @TestTemplate
-    @DisabledOnContainer(value = {TestContainerId.FLINK_1_13, TestContainerId.SPARK_2_4})
+    @DisabledOnContainer(value = {TestContainerId.SPARK_2_4})
     public void testKafkaAvroToAssert(TestContainer container)
             throws IOException, InterruptedException {
         DefaultSeaTunnelRowSerializer serializer =