我使用ApacheFlink1.10批量计算流数据,今天我将ApacheFlinkKubernetes(v1.15.2)pod从机器1移动到机器2,发现所有提交任务记录和任务列表都消失了,发生了什么?最高纪录在记忆里?重新启动apacheflink的kubernetes pod时,我应该保留什么提交记录和任务列表?我只是发现检查点是持久的,但对任务却一无所知。
如果丢失了正在运行的任务历史记录,我必须上传我的任务jar并重新创建所有的任务,那么许多任务都需要重新创建如果丢失了历史记录,有没有可能自动恢复任务?
1条答案
按热度按时间b0zn9rqh1#
可能无法设置的配置包括:
工作经理
历史服务器
更多详情请参见:https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/historyserver.html#configuration