[X] 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);
zhuangchong
commented
2 months ago
Search before asking
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?