(flink-cdc) 07/12: Fix compile.

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch FLINK-38729-2
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git

commit 0faf780792e8994b98d3ddd3cce54faedb907025
Author: lvyanquan <lvyanquan....@alibaba-inc.com>
AuthorDate: Tue Mar 10 08:55:13 2026 +0800

    Fix compile.
---
 .../flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
 
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
index 8ca8eb5cf..001f0ba64 100644
--- 
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
+++ 
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
@@ -18,6 +18,7 @@
 package org.apache.flink.cdc.composer.flink.translator;
 
 import org.apache.flink.api.connector.sink2.SinkWriter;
+import org.apache.flink.api.connector.sink2.WriterInitContext;
 import org.apache.flink.api.dag.Transformation;
 import org.apache.flink.cdc.common.event.Event;
 import org.apache.flink.runtime.jobgraph.OperatorID;
@@ -87,5 +88,10 @@ class DataSinkTranslatorTest {
         public SinkWriter<Event> createWriter(InitContext context) throws 
IOException {
             return null;
         }
+
+        @Override
+        public SinkWriter<Event> createWriter(WriterInitContext context) 
throws IOException {
+            return null;
+        }
     }
 }