[Bug] org.apache.paimon.flink.action.cdc.format.DataFormat IllegalAccessError

[lipeng186]

Search before asking

• I searched in the issues and found nothing similar.

Paimon version

In the master branch, null parameter construction is used during the initialization process of the org.apache.paimon.flink.action.cdc.format.DataFormat class, but there is no null parameter construction method in the corresponding class；
eg:public enum DataFormat {
CANAL_JSON(
CanalRecordParser::new,
KafkaDebeziumJsonDeserializationSchema::new,
CdcJsonDeserializationSchema::new),
OGG_JSON(
OggRecordParser::new,
KafkaDebeziumJsonDeserializationSchema::new,
CdcJsonDeserializationSchema::new),
MAXWELL_JSON(
MaxwellRecordParser::new,
KafkaDebeziumJsonDeserializationSchema::new,
CdcJsonDeserializationSchema::new),
DEBEZIUM_JSON(
DebeziumJsonRecordParser::new,
KafkaDebeziumJsonDeserializationSchema::new,
CdcJsonDeserializationSchema::new),
DEBEZIUM_AVRO(
DebeziumAvroRecordParser::new,
KafkaDebeziumAvroDeserializationSchema::new,
PulsarDebeziumAvroDeserializationSchema::new),
JSON(
JsonRecordParser::new,
KafkaDebeziumJsonDeserializationSchema::new,
CdcJsonDeserializationSchema::new);

Compute Engine

flink1.7.2

Minimal reproduce step

coding error org.apache.paimon.flink.action.cdc.format.DataFormat

What doesn't meet your expectations?

java.lang.IllegalAccessError: no such constructor: org.apache.paimon.flink.action.cdc.kafka.KafkaDebeziumAvroDeserializationSchema

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[zhuangchong]

@lipeng186 How to reproduce your problem?

[lipeng186]

run org.apache.paimon.flink.action.FlinkActions
params : kafka_sync_database