请问用flink-cdc读取tidb写入starrocks,现在总是报下面的错,怎么办?

请教下社区大佬,我用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]

展开
收起
滴滴滴~ 2023-03-21 14:38:32 166 分享 版权
1 条回答
写回答
取消 提交回答
  • TM心跳丢失,可以先看下为什么没有响应,有火焰图的话定位下TM在忙什么,再决定如何调整。 此答案整理自钉群“Flink CDC 社区”

    2023-03-21 16:44:06
    赞同 展开评论

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

收录在圈子:
+ 订阅
还有其他疑问?
咨询AI助理