问题一:Flink CDC报错了,这个应该怎么处理呀?
Flink CDC报错了,这个应该怎么处理呀?
参考答案:
你的tm就没启动,提交的应用肯定失败
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/483347?spm=a2c6h.13066369.question.1.4d426d0cvKpKRi
问题二:Flink代码和报错的截图是这2个,请问一下flink cdc postgresql的数据,用的是官网的demo,报这个错的是什么原因
Flink代码和报错的截图是这2个,请问一下flink cdc postgresql的数据,用的是官网的demo,报这个错的是什么原因:Caused by: java.io.NotSerializableException: com.ververica.cdc.debezium.Validator$$Lambda$14/0x0000000800065840
参考答案:
应该你在自定义序列化的时候类没有序列化这个类,看下你的StringDebeziumDeserializationSchema()方法,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/500291?spm=a2c6h.13066369.question.2.4d426d0c7Bc18e
问题三:这个报错谁能帮忙吗?flink 13.6 + flink_cdc_2.3.0
[org.apache.flink.runtime.source.coordinator.SourceCoordinator]Uncaught exception in the SplitEnumerator for Source Source: MySQL Source while starting the SplitEnumerator.. Triggering job failover. java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava30/com/google/common/util/concurrent/ThreadFactoryBuilder 这个报错谁能帮忙吗?flink 13.6 + flink_cdc_2.3.0
参考答案:
参考文档https://www.cnblogs.com/30go/p/15370240.html
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/500257?spm=a2c6h.13066369.question.3.4d426d0cDH9FyZ
问题四:问一下本地编译flink cdc 源码的时候报错 大家有遇到过的吗?
问一下本地编译flink cdc 源码的时候报错 大家有遇到过的吗?
参考答案:
在pom.xml里找到spotless-check注释掉试试。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/494793?spm=a2c6h.13066369.question.4.4d426d0cZq0yDF
问题五:flink cdc 同步oracle 到 doris报错
Caused by: java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine a43da638-25e2-42dc-a368-a12df187a11c has been removed, this might because the debezium engine has been shutdown due to other errors. at com.ververica.cdc.debezium.utils.DatabaseHistoryUtil.retrieveHistory(DatabaseHistoryUtil.java:77) at com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory.configure(FlinkDatabaseSchemaHistory.java:82) at io.debezium.relational.HistorizedRelationalDatabaseConnectorConfig.getDatabaseHistory(HistorizedRelationalDatabaseConnectorConfig.java:105) at io.debezium.relational.HistorizedRelationalDatabaseSchema.(HistorizedRelationalDatabaseSchema.java:39) at io.debezium.connector.oracle.OracleDatabaseSchema.(OracleDatabaseSchema.java:35) at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:54) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:207) at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:148) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:788) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)
参考答案:
这个错误提示表明Debezium引擎在处理过程中遇到了错误并停止了运行,导致无法检索到引擎的模式记录。可能是由于其他错误导致Debezium引擎关闭,建议检查Debezium引擎的日志以获取更多信息。同时,可以尝试重新启动Debezium引擎并重新运行任务。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/498309?spm=a2c6h.13066369.question.5.4d426d0cfkHft6