Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.paimon.options.Options to field org.apache.flink.cdc.connectors.paimon.sink.PaimonMetadataApplier.catalogOptions of type org.apache.paimon.options.Options in instance of org.apache.flink.cdc.connectors.paimon.sink.PaimonMetadataApplier

[cdjincan]

/opt/soft/jincan/flink-cdc-3.5.0/bin/flink-cdc.sh
-t yarn-application
-Dyarn.application.name=mysql2paimon_yaml
-Dtaskmanager.numberOfTaskSlots=2
-Djobmanager.memory.process.size=2G
-Dtaskmanager.memory.process.size=4G
-Denv.java.opts.all=-XX:+UseG1GC
-Dstate.backend.incremental=true
-Dstate.checkpoint.num-retained=10
-Dstate.backend.type=rocksdb
-Dexecution.checkpointing.interval=30s
-Dclassloader.check-leaked-classloader=false
-Dstate.checkpoints.dir=hdfs:///flink/checkpoint/mysql2paimon_yaml/
--jar /opt/soft/jincan/flink-cdc-pipeline-connector-mysql-3.5.0.jar
--jar /opt/soft/jincan/flink-cdc-pipeline-connector-paimon-3.5.0.jar
--flink-home=/opt/soft/jincan/flink-1.20.1
/opt/soft/jincan/flink-cdc-3.5.0/mysql_to_paimon.yaml

[cdjincan]

@leonardBang this problem has solved？

[leonardBang]

@lvyanquan Could you take a look at this issue when you have time?

[sife0]

remove paimon dependency in pom, rebuild flink-cdc-pipeline-connector-paimon-3.5.0.jar and add dependency paimon-flink-1.20-1.2.0.jar