zhangshenghang commented on code in PR #10152:
URL: https://github.com/apache/seatunnel/pull/10152#discussion_r2602886277
##########
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java:
##########
@@ -1440,8 +1455,10 @@ public void testKafkaProtobufToAssert(TestContainer
container)
@TestTemplate
@DisabledOnContainer(
- type = EngineType.SPARK,
- value = {})
+ value = {},
+ type = {EngineType.SPARK, EngineType.FLINK},
+ disabledReason =
+ "Flink streaming exactly-once requires checkpoint
completion before data is visible in sink topic, which causes timeout in this
test")
public void testKafkaToKafkaExactlyOnceOnStreaming(TestContainer container)
Review Comment:
Why can't Flink run? Such modifications will make it impossible to verify
the functions under Flink.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
