AHeise commented on PR #26518: URL: https://github.com/apache/flink/pull/26518#issuecomment-2839056740
Here are some pointers for the IT. I recently added a [rescale test for KafkaSink ](https://github.com/apache/flink-connector-kafka/blob/5384ab2f3a0bc42e6c3019c151f3b72bb4983926/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java#L397 ) Basic structure: * Have 1 job fail after 1 successful checkpoint * Have a second job resume from the checkpoint I'd place the test in [SinkV2ITCase](https://github.com/apache/flink/blob/8bd248ee731aeb4a3220129e151dfb8cb5f0719e/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2ITCase.java#L57) or a new SinkRescaleITCase and use the [TestSinkV2](https://github.com/apache/flink/blob/8bd248ee731aeb4a3220129e151dfb8cb5f0719e/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/TestSinkV2.java#L62). The TestSink uses the global committer when you enable post commit topology (`withPostCommitTopology(true)`) while you build it. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
