[hotfix] Test properly default JobMasterId in JobMaster#suspendExecution

上级 4fc019a9
......@@ -791,7 +791,7 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast
private Acknowledge suspendExecution(final Throwable cause) {
validateRunsInMainThread();
if (getFencingToken() == null) {
if (Objects.equals(JobMasterId.INITIAL_JOB_MASTER_ID, getFencingToken())) {
log.debug("Job has already been suspended or shutdown.");
return Acknowledge.get();
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册