提交 884d3e2a 编写于 作者: M Maximilian Michels

[FLINK-4258] fix potential NPE in SavepointCoordinator

上级 9bcbcf4a
......@@ -200,8 +200,6 @@ public class SavepointCoordinator extends CheckpointCoordinator {
Savepoint savepoint = savepointStore.loadSavepoint(savepointPath);
long recoveryTimestamp = System.currentTimeMillis();
for (TaskState taskState : savepoint.getTaskStates()) {
ExecutionJobVertex executionJobVertex = tasks.get(taskState.getJobVertexID());
......@@ -292,8 +290,9 @@ public class SavepointCoordinator extends CheckpointCoordinator {
Promise<String> promise = savepointPromises.remove(checkpoint.getCheckpointID());
if (promise == null) {
LOG.info("Pending savepoint with ID " + checkpoint.getCheckpointID() + " has been " +
LOG.warn("Pending savepoint with ID " + checkpoint.getCheckpointID() + " has been " +
"removed before receiving acknowledgment.");
return;
}
// Sanity check
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册