yzeng1618 commented on code in PR #10152:
URL: https://github.com/apache/seatunnel/pull/10152#discussion_r2606784304
##########
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:
It has been removed now. It was originally added only because the E2E tests
kept failing.
--
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]
