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
The following commit(s) were added to refs/heads/release-3.6 by this push:
new 5e512cb4b [hotfix] Fix e2e test error for StarRocks Pipeline.
5e512cb4b is described below
commit 5e512cb4be046884a87880a3bb0c4e3134bfac28
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 {
