fix: stopwatch exception in FrequentTaskTracker

This commit is contained in:
tjq 2020-10-08 15:47:38 +08:00
parent 71dbe05647
commit a9e4ed6262
2 changed files with 3 additions and 6 deletions

View File

@ -29,7 +29,7 @@
<file>${LOG_PATH}/powerjob-agent-error.log</file> <file>${LOG_PATH}/powerjob-agent-error.log</file>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<FileNamePattern>${LOG_PATH}/powerjob-agent-error.%d{yyyy-MM-dd}.log</FileNamePattern> <FileNamePattern>${LOG_PATH}/powerjob-agent-error.%d{yyyy-MM-dd}.log</FileNamePattern>
<MaxHistory>7</MaxHistory> <MaxHistory>3</MaxHistory>
</rollingPolicy> </rollingPolicy>
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
@ -49,7 +49,7 @@
<file>${LOG_PATH}/powerjob-agent-application.log</file> <file>${LOG_PATH}/powerjob-agent-application.log</file>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<FileNamePattern>${LOG_PATH}/powerjob-agent-application.%d{yyyy-MM-dd}.log</FileNamePattern> <FileNamePattern>${LOG_PATH}/powerjob-agent-application.%d{yyyy-MM-dd}.log</FileNamePattern>
<MaxHistory>7</MaxHistory> <MaxHistory>3</MaxHistory>
</rollingPolicy> </rollingPolicy>
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>

View File

@ -295,14 +295,11 @@ public class FrequentTaskTracker extends TaskTracker {
newLastTask.setAddress(OhMyWorker.getWorkerAddress()); newLastTask.setAddress(OhMyWorker.getWorkerAddress());
submitTask(Lists.newArrayList(newLastTask)); submitTask(Lists.newArrayList(newLastTask));
} }
} }
} }
// 舍去一切重试机制反正超时就失败 // 舍去一切重试机制反正超时就失败
log.debug("[TaskTracker-{}] check status using {}.", instanceId, stopwatch.stop());
} }
log.debug("[TaskTracker-{}] check status using {}.", instanceId, stopwatch);
} }
private void reportStatus() { private void reportStatus() {