flink任务无法找到session，导致数据链路中断

问答 问题
1
  • nebula 版本：3.1.0
  • 部署方式：分布式
  • 安装方式：RPM
  • 是否为线上版本：Y
  • 硬件信息
    • 磁盘（ 推荐使用 SSD）: 1000GB SSD
    • CPU、内存信息: 40 core 80g mermory
  • 问题的具体描述
    flink读取kafka数据写入nebula，发现数据未及时更新，排查发现flink任务找不到session，导致数据写入失败
write data failed: Get sessionId[1656743537824672] failed: Session `1656743537824672' not found: Session not existed!
2

现在解决了吗?

3

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。