Skip to content

D
dlink
Unverified Commit 0917751d authored by hxp0618's avatar hxp0618 Committed by GitHub
Browse files
Options

[Feature] [dlink-admin] 修改重复判断的问题 (#765) 

Co-authored-by: 's avatarhuangxp <hxp0618@gmail.com>
parent 0c77ee42
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
dlink-admin/src/main/java/com/dlink/service/impl/TaskServiceImpl.java
View file @ 0917751d
...@@ -757,7 +757,7 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen ...@@ -757,7 +757,7 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen
jobInfoDetail.setJobHistory(jobHistory); jobInfoDetail.setJobHistory(jobHistory);
String status = jobInfoDetail.getInstance().getStatus(); String status = jobInfoDetail.getInstance().getStatus();
boolean jobStatusChanged = false; boolean jobStatusChanged = false;
if (Asserts.isNull(jobInfoDetail.getJobHistory().getJob()) || Asserts.isNull(jobInfoDetail.getJobHistory().getJob())) { if (Asserts.isNull(jobInfoDetail.getJobHistory().getJob())) {
jobInfoDetail.getInstance().setStatus(JobStatus.UNKNOWN.getValue()); jobInfoDetail.getInstance().setStatus(JobStatus.UNKNOWN.getValue());
} else { } else {
jobInfoDetail.getInstance().setDuration(jobInfoDetail.getJobHistory().getJob().get(FlinkRestResultConstant.JOB_DURATION).asLong() / 1000); jobInfoDetail.getInstance().setDuration(jobInfoDetail.getJobHistory().getJob().get(FlinkRestResultConstant.JOB_DURATION).asLong() / 1000);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment