Update JobSender.java

helango-seabiscuit · Jan 19, 2017 · fb5590c · fb5590c
1 parent c2175c5
commit fb5590c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/sender/JobSender.java b/lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/sender/JobSender.java
@@ -68,7 +68,7 @@ private List<JobPo> fetchJob(String taskTrackerNodeGroup, String taskTrackerIden
 
             // IMPORTANT: 这里要先切换队列
             try {
-                jobPo.setGmtModified(jobPo.getGmtCreated());
+                jobPo.setGmtModified(SystemClock.now());
                 appContext.getExecutingJobQueue().add(jobPo);
             } catch (DupEntryException e) {
                 LOGGER.warn("ExecutingJobQueue already exist:" + JSON.toJSONString(jobPo));