This is an automated email from the ASF dual-hosted git repository. kunni pushed a commit to branch release-3.6 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit e06639a62d98c233d25bdc689b975dcbd186bb24 Author: lvyanquan <[email protected]> AuthorDate: Sat Mar 21 14:21:44 2026 +0800 [hotfix] Fix e2e test error for StarRocks Pipeline. --- .../main/java/org/apache/flink/api/connector/sink2/StatefulSink.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java b/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java index 1298f9e6b..391d12de7 100644 --- a/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java +++ b/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java @@ -35,6 +35,8 @@ import java.util.Collection; public interface StatefulSink<InputT, WriterStateT> extends Sink<InputT>, SupportsWriterState<InputT, WriterStateT> { + SinkWriter<InputT> createWriter(InitContext initContext) throws IOException; + @Override default SinkWriter<InputT> createWriter(WriterInitContext writerInitContext) throws IOException {
