请教下社区大佬,我用flink-cdc读取tidb写入starrocks,tidb版本是5.7.25-TiDB-v5.0.1,我看tidb-cdc好像只支持5.1.x以后的版本,现在总是报下面的错,调内存和并发度也没有用,这种应该怎么处理,只能升级tidb么? java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id localhost:37824-16fc2c timed out. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1435) ~[flink-dist-1.16.1.jar:1.16.1] at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:155) ~[flink-dist-1.16.1.jar:1.16.1] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_172] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_172]
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
TM心跳丢失,可以先看下为什么没有响应,有火焰图的话定位下TM在忙什么,再决定如何调整。 此答案整理自钉群“Flink CDC 社区”
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。