Check allocationIdOnLastStatusUpdate when trying to detect whether a task is stale.
This commit is contained in:
parent
b142d7e29c
commit
78b844e79b
|
@ -366,7 +366,7 @@ public final class PersistentTasksCustomMetaData extends AbstractNamedDiffable<M
|
|||
* to a new executor node and the status hasn't been updated then the task status is stale.
|
||||
*/
|
||||
public boolean isCurrentStatus() {
|
||||
return allocationIdOnLastStatusUpdate == allocationId;
|
||||
return allocationIdOnLastStatusUpdate != null && allocationIdOnLastStatusUpdate == allocationId;
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
Loading…
Reference in New Issue