FlinkSQL启动报错could not send message网站首页 其他

FlinkSQL启动报错could not send message

500佰 2025-03-20 00:01:02

简介FlinkSQL启动报错could not send message

个人主页：500佰

个人专栏：Flink-登上高阶

#Flink常见故障 #大数据 #生产环境真实案例 #Flink #流式计算 #流批一体 #整理 #经验总结

说明：此篇总结Flink on Hudi常见故障多案例处理方案结合自身经历总结不易 +关注 +收藏欢迎留言

更多Flink案例汇总方案解决方案：

Flink业务常见故障多案例解决方案

Flink on Hudi业务常见故障多案例解决方案

FlinkSQL启动报错could not send message

问题

FlinkSQL启动报错：

Caused by: org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException: Could not send message [LocalFencedMessage(ereddgfgr4324655684, 

LocalRpcInvocation(JobMasterGateway.requestJob(Time)))] from sender [Actor[akka://flink/temp/jobmanager_2$B]] to recipient [Actor[akka://flink/user/rpc/jobmanager_2#1948396874]], because the recipient is unreachable. This can either mean that the recipient has been terminated or that the remote RpcService is currently not reachable

原因

FlinkSQL写入的表结构和spark手动创建的表结构不一致。可能Flink创建了bucket桶表，但是spark手动创建的普通bloom索引表。

解决方法

去掉flinksql分桶参数或spark创建分桶表。