diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
index 77dea3b7b362..d9a61b579f21 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/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 =