|
@@ -61,7 +61,7 @@ public class JobScheduler {
|
|
|
jobStatus.setAppId(holder.getJobId());
|
|
jobStatus.setAppId(holder.getJobId());
|
|
|
// 如果 running 为 true,说明已经过了 semaphore.acquire()
|
|
// 如果 running 为 true,说明已经过了 semaphore.acquire()
|
|
|
jobStatus.setStatus(holder.isRunning() ? "RUNNING" : "WAITING");
|
|
jobStatus.setStatus(holder.isRunning() ? "RUNNING" : "WAITING");
|
|
|
- jobStatus.setWaitTime((System.currentTimeMillis() - holder.getSubmitTime()/1000));
|
|
|
|
|
|
|
+ jobStatus.setWaitTime((System.currentTimeMillis() - holder.getSubmitTime())/1000);
|
|
|
return jobStatus;
|
|
return jobStatus;
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
}
|
|
}
|