Repository: hive Updated Branches: refs/heads/master fe3a457d7 -> f0434c5b5
HIVE-20672 : Logging thread in LlapTaskSchedulerService should report every fixed interval (Jaume M, reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f0434c5b Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f0434c5b Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f0434c5b Branch: refs/heads/master Commit: f0434c5b5c591c7c1af0840c4dd3b08e53614869 Parents: fe3a457 Author: sergey <ser...@apache.org> Authored: Thu Oct 4 16:46:41 2018 -0700 Committer: sergey <ser...@apache.org> Committed: Thu Oct 4 16:46:41 2018 -0700 ---------------------------------------------------------------------- .../hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f0434c5b/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java ---------------------------------------------------------------------- diff --git a/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java b/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java index b748c7e..7e8299d 100644 --- a/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java +++ b/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java @@ -732,9 +732,9 @@ public class LlapTaskSchedulerService extends TaskScheduler { } writeLock.lock(); try { - scheduledLoggingExecutor.schedule(new Callable<Void>() { + scheduledLoggingExecutor.scheduleAtFixedRate(new Runnable() { @Override - public Void call() throws Exception { + public void run() { readLock.lock(); try { if (dagRunning) { @@ -743,9 +743,8 @@ public class LlapTaskSchedulerService extends TaskScheduler { } finally { readLock.unlock(); } - return null; } - }, 10000L, TimeUnit.MILLISECONDS); + }, 0, 10000L, TimeUnit.MILLISECONDS); nodeEnablerFuture = nodeEnabledExecutor.submit(nodeEnablerCallable); Futures.addCallback(nodeEnablerFuture, new LoggingFutureCallback("NodeEnablerThread", LOG));
