优化JobTracker吞吐量[性能优化]

helango-seabiscuit · Nov 7, 2016 · 689663b · 689663b
1 parent 688b9aa
commit 689663b
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/lts-admin/src/main/java/com/github/ltsopensource/admin/web/api/CronJobQueueApi.java b/lts-admin/src/main/java/com/github/ltsopensource/admin/web/api/CronJobQueueApi.java
@@ -160,7 +160,7 @@ public RestfulResponse cronJobSuspend(JobQueueReq request) {
             appContext.getSuspendJobQueue().add(jobPo);
         } catch (DupEntryException e) {
             LOGGER.error(e.getMessage(), e);
-            return Builder.build(false, "改任务已经被暂停, 请检查暂停队列");
+            return Builder.build(false, "该任务已经被暂停, 请检查暂停队列");
         } catch (Exception e) {
             LOGGER.error(e.getMessage(), e);
             return Builder.build(false, "移动任务到暂停队列失败, error:" + e.getMessage());

diff --git a/lts-core/src/main/java/com/github/ltsopensource/cmd/HttpCmdServer.java b/lts-core/src/main/java/com/github/ltsopensource/cmd/HttpCmdServer.java
@@ -36,7 +36,7 @@ public void start() throws HttpCmdException {
                 // 开启监听命令
                 acceptor = new HttpCmdAcceptor(getServerSocket(), context);
                 acceptor.start();
-                LOGGER.info("===========================================================================================\n" +
+                LOGGER.info("\n===========================================================================================\n" +
                         "Start succeed at port {}\n" +
                         "===========================================================================================", port);
             }

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
@@ -38,15 +38,17 @@ public SendResult send(String taskTrackerNodeGroup, String taskTrackerIdentity,
         SendResult sendResult = invoker.invoke(jobPos);
 
         if (sendResult.isSuccess()) {
+            List<JobLogPo> jobLogPos = new ArrayList<JobLogPo>(jobPos.size());
             for (JobPo jobPo : jobPos) {
                 // 记录日志
                 JobLogPo jobLogPo = JobDomainConverter.convertJobLog(jobPo);
                 jobLogPo.setSuccess(true);
                 jobLogPo.setLogType(LogType.SENT);
                 jobLogPo.setLogTime(SystemClock.now());
                 jobLogPo.setLevel(Level.INFO);
-                appContext.getJobLogger().log(jobLogPo);
+                jobLogPos.add(jobLogPo);
             }
+            appContext.getJobLogger().log(jobLogPos);
         }
         return sendResult;
     }

diff --git a/lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/support/JobPusher.java b/lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/support/JobPusher.java
@@ -251,7 +251,6 @@ private void resumeJob(JobPo jobPo) {
         boolean needResume = true;
         try {
             jobPo.setIsRunning(true);
-            jobPo.setGmtModified(SystemClock.now());
             appContext.getExecutableJobQueue().add(jobPo);
         } catch (DupEntryException e) {
             LOGGER.warn("ExecutableJobQueue already exist:" + JSON.toJSONString(jobPo));