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

  • 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!

现在解决了吗?

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

浙ICP备20010487号