This is an automated email from the ASF dual-hosted git repository.
yuxiqian 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 b5927d01bd [FLINK-40507][connect/paimon] Upgrade Paimon SDK to 2.0.0
b5927d01bd is described below
commit b5927d01bd56785111537ce79665a3ebceec28bb
Author: Pei Yu <[email protected]>
AuthorDate: Tue Sep 1 09:40:14 2026 +0800
[FLINK-40507][connect/paimon] Upgrade Paimon SDK to 2.0.0
Signed-off-by: Pei Yu <[email protected]>
---
.../flink-cdc-pipeline-connector-paimon/pom.xml | 2 +-
.../apache/flink/cdc/connectors/paimon/sink/v2/PreCommitOperator.java | 3 ++-
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml | 2 +-
3 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
index a8cbc2a64f..b2e1c5de71 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
@@ -29,7 +29,7 @@ limitations under the License.
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
<properties>
- <paimon.version>1.4.2</paimon.version>
+ <paimon.version>2.0.0</paimon.version>
<hadoop.version>2.8.5</hadoop.version>
<hive.version>2.3.9</hive.version>
<mockito.version>3.12.4</mockito.version>
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/PreCommitOperator.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/PreCommitOperator.java
index c3fefd3a22..f8c15ce604 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/PreCommitOperator.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/PreCommitOperator.java
@@ -31,6 +31,7 @@ import org.apache.paimon.flink.FlinkCatalogFactory;
import org.apache.paimon.flink.sink.Committer;
import org.apache.paimon.flink.sink.MultiTableCommittable;
import org.apache.paimon.flink.sink.StoreMultiCommitter;
+import org.apache.paimon.flink.sink.state.OperatorBackendStateStore;
import org.apache.paimon.manifest.WrappedManifestCommittable;
import org.apache.paimon.options.Options;
import org.slf4j.Logger;
@@ -85,7 +86,7 @@ public class PreCommitOperator
getMetricGroup(),
true,
context.isRestored(),
- context.getOperatorStateStore(),
+ new
OperatorBackendStateStore(context.getOperatorStateStore()),
getRuntimeContext().getTaskInfo().getNumberOfParallelSubtasks(),
getRuntimeContext().getTaskInfo().getIndexOfThisSubtask()));
}
diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
index 52e3dc6aa1..37aec13dcf 100644
--- a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
+++ b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
@@ -32,7 +32,7 @@ limitations under the License.
<flink-major-1.20>1.20</flink-major-1.20>
<mysql.driver.version>8.0.27</mysql.driver.version>
<starrocks.connector.version>1.2.14_flink-${flink-major-1.20}</starrocks.connector.version>
- <paimon.version>1.4.2</paimon.version>
+ <paimon.version>2.0.0</paimon.version>
<flink.release.download.skip>false</flink.release.download.skip>
<flink.release.name>flink-${flink.version}-bin-scala_${scala.binary.version}.tgz</flink.release.name>
<flink.release.mirror>https://dlcdn.apache.org/flink/flink-${flink.version}</flink.release.mirror>
