You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2015/09/21 23:11:31 UTC
hive git commit: HIVE-9898: LLAP: Sort out issues with UGI and cached
FileSystems (Prasanth Jayachandran)
Repository: hive
Updated Branches:
refs/heads/llap 683fb689c -> 7148ea090
HIVE-9898: LLAP: Sort out issues with UGI and cached FileSystems (Prasanth Jayachandran)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/7148ea09
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/7148ea09
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/7148ea09
Branch: refs/heads/llap
Commit: 7148ea0903059733b234359e600df479c82b9673
Parents: 683fb68
Author: Prasanth Jayachandran <j....@gmail.com>
Authored: Mon Sep 21 16:11:18 2015 -0500
Committer: Prasanth Jayachandran <j....@gmail.com>
Committed: Mon Sep 21 16:11:18 2015 -0500
----------------------------------------------------------------------
.../hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/7148ea09/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java
----------------------------------------------------------------------
diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java
index e0bd48a..157f9d3 100644
--- a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java
+++ b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskRunnerCallable.java
@@ -27,8 +27,8 @@ import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
-import com.google.common.annotations.VisibleForTesting;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.hive.common.CallableWithNdc;
import org.apache.hadoop.hive.llap.daemon.FragmentCompletionHandler;
import org.apache.hadoop.hive.llap.daemon.HistoryLogger;
@@ -62,6 +62,7 @@ import org.apache.tez.runtime.task.TezTaskRunner2;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Stopwatch;
import com.google.common.collect.HashMultimap;
import com.google.common.collect.Multimap;
@@ -232,8 +233,7 @@ public class TaskRunnerCallable extends CallableWithNdc<TaskRunner2Result> {
isCompleted.set(true);
return result;
} finally {
- // TODO Fix UGI and FS Handling. Closing UGI here causes some errors right now.
- // FileSystem.closeAllForUGI(taskUgi);
+ FileSystem.closeAllForUGI(taskUgi);
LOG.info("ExecutionTime for Container: " + request.getContainerIdString() + "=" +
runtimeWatch.stop().elapsedMillis());
if (LOG.isDebugEnabled()) {