Re:[State Backend] 请教个问题,checkpoint恢复失败

2019-05-02 文章 Yun Tang
Hi 错误栈是恢复state时候,读取的stream被关闭了,如果HDFS本身没有出问题的话,这个应该不是root cause,日志里面还有其他异常么? 祝好 唐云 发自我的小米手机 在 eric ,2019年4月30日 16:30写道: 大家好: 刚接触flink, 跑了个测试state checkpoint的程序: 1) 数据源是socket模式,用的是keyed state backend; 提交job跑一会 2) 然后关闭数据源的socket,这时job会进入failed状态 3) 停几秒,把数据源socket重新打开 4) 这时flink会重连socket, 对job

[State Backend] ????????????checkpoint????????

2019-05-02 文章 eric
??: ??flink, ??state checkpoint??: 1) socketkeyed state backend; job?? 2) socket??job??failed 3) socket 4) flink??socket, ??job??, ??MapState ??