3.0.1升级到3.1.1报错 cannot be cast to io.debezium.spi.converter.CustomConverter 怎么解决

[heyuhang]

Caused by: java.lang.ClassCastException: com.kunlun.etl.sink.MySqlDateTimeConverter cannot be cast to io.debezium.spi.converter.CustomConverter
at io.debezium.config.CommonConnectorConfig.lambda$getCustomConverters$1(CommonConnectorConfig.java:767)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
at io.debezium.config.CommonConnectorConfig.getCustomConverters(CommonConnectorConfig.java:771)
at io.debezium.config.CommonConnectorConfig.(CommonConnectorConfig.java:631)
at io.debezium.relational.RelationalDatabaseConnectorConfig.(RelationalDatabaseConnectorConfig.java:629)
at io.debezium.connector.postgresql.PostgresConnectorConfig.(PostgresConnectorConfig.java:1103)
at org.apache.flink.cdc.connectors.postgres.source.config.PostgresSourceConfig.getDbzConnectorConfig(PostgresSourceConfig.java:107)
at org.apache.flink.cdc.connectors.postgres.source.PostgresDialect.openJdbcConnection(PostgresDialect.java:82)
at org.apache.flink.cdc.connectors.postgres.source.PostgresDialect.discoverDataCollections(PostgresDialect.java:161)
at org.apache.flink.cdc.connectors.postgres.source.PostgresDialect.discoverDataCollections(PostgresDialect.java:64)
at org.apache.flink.cdc.connectors.postgres.source.PostgresSourceBuilder$PostgresIncrementalSource.createEnumerator(PostgresSourceBuilder.java:314)
... 10 more