diff --git llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java index b748c7e373..7e8299d156 100644 --- llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java +++ llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java @@ -732,9 +732,9 @@ public void start() throws IOException { } writeLock.lock(); try { - scheduledLoggingExecutor.schedule(new Callable() { + scheduledLoggingExecutor.scheduleAtFixedRate(new Runnable() { @Override - public Void call() throws Exception { + public void run() { readLock.lock(); try { if (dagRunning) { @@ -743,9 +743,8 @@ public Void call() throws Exception { } finally { readLock.unlock(); } - return null; } - }, 10000L, TimeUnit.MILLISECONDS); + }, 0, 10000L, TimeUnit.MILLISECONDS); nodeEnablerFuture = nodeEnabledExecutor.submit(nodeEnablerCallable); Futures.addCallback(nodeEnablerFuture, new LoggingFutureCallback("NodeEnablerThread", LOG));