This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 8a7fdd5ae [minor][cdc-connector][paimon] Remove duplicate interface
implements
8a7fdd5ae is described below
commit 8a7fdd5ae34a4b39a5e115f17b3662755fd47e71
Author: joyCurry30 <[email protected]>
AuthorDate: Thu Jun 6 09:28:21 2024 +0800
[minor][cdc-connector][paimon] Remove duplicate interface implements
---
.../org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java
index 24002bd24..5e310b2c3 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java
@@ -20,7 +20,6 @@ package org.apache.flink.cdc.connectors.paimon.sink.v2;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.connector.sink2.Committer;
import org.apache.flink.api.connector.sink2.Sink;
-import org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink;
import org.apache.flink.core.io.SimpleVersionedSerializer;
import org.apache.flink.streaming.api.connector.sink2.CommittableMessage;
import
org.apache.flink.streaming.api.connector.sink2.CommittableMessageTypeInfo;
@@ -36,9 +35,7 @@ import org.apache.paimon.table.sink.CommitMessageSerializer;
/**
* A {@link Sink} for Paimon. Maintain this package until Paimon has it own
sinkV2 implementation.
*/
-public class PaimonSink<InputT>
- implements TwoPhaseCommittingSink<InputT, MultiTableCommittable>,
- WithPreCommitTopology<InputT, MultiTableCommittable> {
+public class PaimonSink<InputT> implements WithPreCommitTopology<InputT,
MultiTableCommittable> {
// provided a default commit user.
public static final String DEFAULT_COMMIT_USER = "admin";
