[hotfix] Fix compile error due to implict code conflicts

luoyuxia · web-flow · commit 2d59a4911649 · 2025-06-06T12:10:27.000+08:00
This closes #1021.
diff --git a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/source/TestingLakeTieringFactory.java b/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/source/TestingLakeTieringFactory.java
@@ -16,6 +16,7 @@
 
 package com.alibaba.fluss.flink.tiering.source;
 
+import com.alibaba.fluss.lakehouse.committer.CommitterInitContext;
 import com.alibaba.fluss.lakehouse.committer.LakeCommitter;
 import com.alibaba.fluss.lakehouse.serializer.SimpleVersionedSerializer;
 import com.alibaba.fluss.lakehouse.writer.LakeTieringFactory;
@@ -40,7 +41,8 @@ public SimpleVersionedSerializer<TestingWriteResult> getWriteResultSerializer()
     }
 
     @Override
-    public LakeCommitter<TestingWriteResult, Integer> createLakeCommitter() throws IOException {
+    public LakeCommitter<TestingWriteResult, Integer> createLakeCommitter(
+            CommitterInitContext committerInitContext) throws IOException {
         throw new UnsupportedOperationException("method createLakeCommitter is not supported.");
     }
 

Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@`
`16`	`16`
`17`	`17`	`package com.alibaba.fluss.flink.tiering.source;`
`18`	`18`
	`19`	`+import com.alibaba.fluss.lakehouse.committer.CommitterInitContext;`
`19`	`20`	`import com.alibaba.fluss.lakehouse.committer.LakeCommitter;`
`20`	`21`	`import com.alibaba.fluss.lakehouse.serializer.SimpleVersionedSerializer;`
`21`	`22`	`import com.alibaba.fluss.lakehouse.writer.LakeTieringFactory;`
`@@ -40,7 +41,8 @@ public SimpleVersionedSerializer<TestingWriteResult> getWriteResultSerializer()`
`40`	`41`	`}`
`41`	`42`
`42`	`43`	`@Override`
`43`		`- public LakeCommitter<TestingWriteResult, Integer> createLakeCommitter() throws IOException {`
	`44`	`+ public LakeCommitter<TestingWriteResult, Integer> createLakeCommitter(`
	`45`	`+ CommitterInitContext committerInitContext) throws IOException {`
`44`	`46`	`throw new UnsupportedOperationException("method createLakeCommitter is not supported.");`
`45`	`47`	`}`
`46`	`48`