Skip to content

Commit

Permalink
Move TimedSupervisorTask logs to debug level as they are already
Browse files Browse the repository at this point in the history
measured by metrics.
  • Loading branch information
qiangdavidliu committed Oct 4, 2017
1 parent d2dbee8 commit 7ef6aaf
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public void run() {
delay.set(timeoutMillis);
threadPoolLevelGauge.set((long) executor.getActiveCount());
} catch (TimeoutException e) {
logger.error("task supervisor timed out", e);
logger.debug("task supervisor timed out", e);
timeoutCounter.increment();

long currentDelay = delay.get();
Expand All @@ -74,17 +74,17 @@ public void run() {

} catch (RejectedExecutionException e) {
if (executor.isShutdown() || scheduler.isShutdown()) {
logger.warn("task supervisor shutting down, reject the task", e);
logger.debug("task supervisor shutting down, reject the task", e);
} else {
logger.error("task supervisor rejected the task", e);
logger.debug("task supervisor rejected the task", e);
}

rejectedCounter.increment();
} catch (Throwable e) {
if (executor.isShutdown() || scheduler.isShutdown()) {
logger.warn("task supervisor shutting down, can't accept the task");
logger.debug("task supervisor shutting down, can't accept the task");
} else {
logger.error("task supervisor threw an exception", e);
logger.debug("task supervisor threw an exception", e);
}

throwableCounter.increment();
Expand Down

0 comments on commit 7ef6aaf

Please sign in to comment.