当正常手动重启yarn后,之前flink job也丢失了,如何能够自动恢复?
目前想到的做法是:
重启前先,保存每个job的savepoint
重启yarn
启动flink(通过yarn-session.sh -d 启动)
重新提交jobs(从第一步的savepoint中恢复)
感觉很麻烦!!
当正常手动重启yarn后,之前flink job也丢失了,如何能够自动恢复?
目前想到的做法是:
重启前先,保存每个job的savepoint
重启yarn
启动flink(通过yarn-session.sh -d 启动)
重新提交jobs(从第一步的savepoint中恢复)
感觉很麻烦!!