flinkcdc之前启动一切正常,过了两礼拜就不行了怎么办?

flinkcdc之前启动一切正常,过了两礼拜就不行了?
08:30:51.471 [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator - Starting split enumerator for source Source: OracleParallelSource.
08:30:51.507 [flink-akka.actor.default-dispatcher-8] ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator - Failed to create Source Enumerator for source Source: OracleParallelSource
java.lang.NoSuchMethodError: 'io.debezium.config.Field io.debezium.config.Field.withType(org.apache.flink.cdc.connectors.shaded.org.apache.kafka.common.config.ConfigDef$Type)'
这是我的flink和cdc的版本image.png

展开
收起
夹心789 2024-05-28 16:48:43 88 分享 版权
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理