You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/10/04 23:46:37 UTC
hive git commit: HIVE-20672 : Logging thread in
LlapTaskSchedulerService should report every fixed interval (Jaume M,
reviewed by Sergey Shelukhin)
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 <se...@apache.org>
Authored: Thu Oct 4 16:46:41 2018 -0700
Committer: sergey <se...@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));