Skip to content

Commit

Permalink
#509 refactor
Browse files Browse the repository at this point in the history
  • Loading branch information
he7g committed Sep 25, 2018
1 parent 2f01b10 commit 1ab058a
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -492,12 +492,12 @@ private void shutdownUnfinishJobs() {
public void run() {
try {
if (!regCenter.isConnected() || jobScheduler.getCurrentConf().isEnabled()) {
LogUtils.info(log, jobName, "job {} is enabled, start to force shutdown");
LogUtils.info(log, jobName, "job is enabled, start to force shutdown");
jobScheduler.stopJob(true);
}
jobScheduler.shutdown(false);
} catch (Throwable t) {
LogUtils.error(log, jobName, "job {} fail to shutdown", jobName, t);
LogUtils.error(log, jobName, "job fail to shutdown", t);
}
}
}));
Expand Down Expand Up @@ -640,7 +640,7 @@ protected boolean isAllowedToBeGracefulShutdown(JobConfiguration currentConf) {
JobType jobType = JobType.valueOf(jobTypeValue);
return ALLOWED_GRACEFUL_SHUTDOWN_TYPES.contains(jobType);
} catch (Exception e) {
LogUtils.warn(log, currentConf.getJobName(), "no such job type:{}", jobTypeValue);
LogUtils.warn(log, currentConf.getJobName(), "no such job type:{}", jobTypeValue, e);
return false;
}
}
Expand Down

0 comments on commit 1ab058a

Please sign in to comment.