starrocks版本:3.3.14 flink版本:1.17 starrocks flink connector版本:1.2.9 # 现象 使用flink写入数据到starrocks,配置了3个jdbc_url和3个load_url,对应3个fe。当starrocks某个fe宕机(后续恢复)时,flink已经无法写入数据,但是运行的算子task没有报错,依然显示running状态,直到flink开始保存checkpoint时,才在checkpoint中收到报错。 # 存在问题 一、flink无法向starrocks写入数据时,connector不抛出异常,导致无法第一时间发现 二、在starrocks的fe节点宕机并恢复的过程中,flink connector无法自动重试连接,一旦fe宕机,就无法写入数据