Flink 从Checkpoint恢复失败
看你的原义是要保存位点后恢复,要先保存 savepoint,参考:https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/savepoints.html#triggering-savepointsbin/flink savepoint :jobId [:targetDirectory]bin/flink run -s :savepointPath [:runArgs]如果是从checkpoint恢复,这个是自动的,只要设置了checkpoint path即可,不需要用 flink run -s
赞0
踩1