diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java index a9a9874..7afacee 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java @@ -24,7 +24,7 @@ import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.shims.ShimLoader; -import org.apache.hadoop.security.UserGroupInformation; +//import org.apache.hadoop.security.UserGroupInformation; /** * SecureCmdDoAs - Helper class for setting parameters and env necessary for @@ -48,8 +48,8 @@ public String addArg(String cmdline) throws HiveException { } public void addEnv(Map env){ - env.put(UserGroupInformation.HADOOP_TOKEN_FILE_LOCATION, - tokenPath.toUri().getPath()); +// env.put(UserGroupInformation.HADOOP_TOKEN_FILE_LOCATION, +// tokenPath.toUri().getPath()); } } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index ab369f0..b11254c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -32,7 +32,7 @@ import java.util.Set; import java.util.UUID; -import org.apache.commons.io.FileUtils; +//import org.apache.commons.io.FileUtils; import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -742,13 +742,13 @@ public void close() throws IOException { File resourceDir = new File(getConf().getVar(HiveConf.ConfVars.DOWNLOADED_RESOURCES_DIR)); LOG.debug("Removing resource dir " + resourceDir); - try { - if (resourceDir.exists()) { - FileUtils.deleteDirectory(resourceDir); - } - } catch (IOException e) { - LOG.info("Error removing session resource dir " + resourceDir, e); - } +// try { +// if (resourceDir.exists()) { +// FileUtils.deleteDirectory(resourceDir); +// } +// } catch (IOException e) { +// LOG.info("Error removing session resource dir " + resourceDir, e); +// } } /** diff --git a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java index 7254491..56f220a 100644 --- a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java +++ b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java @@ -26,7 +26,7 @@ import java.util.Map; import java.util.Set; -import org.apache.commons.io.FileUtils; +//import org.apache.commons.io.FileUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hive.conf.HiveConf;