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 2015/06/13 03:28:18 UTC
[20/50] [abbrv] hive git commit: HIVE-10415
hive.start.cleanup.scratchdir configuration is not taking effect (Chinna via
Jimmy)
HIVE-10415 hive.start.cleanup.scratchdir configuration is not taking effect (Chinna via Jimmy)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/34e050b5
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/34e050b5
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/34e050b5
Branch: refs/heads/llap
Commit: 34e050b533145cd1a57dca0f5f375072b896d345
Parents: d4e34e8
Author: Jimmy Xiang <jx...@cloudera.com>
Authored: Tue Jun 9 13:00:38 2015 -0700
Committer: Jimmy Xiang <jx...@cloudera.com>
Committed: Tue Jun 9 13:08:30 2015 -0700
----------------------------------------------------------------------
service/src/java/org/apache/hive/service/server/HiveServer2.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/34e050b5/service/src/java/org/apache/hive/service/server/HiveServer2.java
----------------------------------------------------------------------
diff --git a/service/src/java/org/apache/hive/service/server/HiveServer2.java b/service/src/java/org/apache/hive/service/server/HiveServer2.java
index 7820ed5..0959cba 100644
--- a/service/src/java/org/apache/hive/service/server/HiveServer2.java
+++ b/service/src/java/org/apache/hive/service/server/HiveServer2.java
@@ -46,6 +46,7 @@ import org.apache.hadoop.hive.common.JvmPauseMonitor;
import org.apache.hadoop.hive.common.LogUtils;
import org.apache.hadoop.hive.common.LogUtils.LogInitializationException;
import org.apache.hadoop.hive.common.metrics.common.MetricsFactory;
+import org.apache.hadoop.hive.common.ServerUtils;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
import org.apache.hadoop.hive.ql.exec.spark.session.SparkSessionManagerImpl;
@@ -351,6 +352,8 @@ public class HiveServer2 extends CompositeService {
maxAttempts = hiveConf.getLongVar(HiveConf.ConfVars.HIVE_SERVER2_MAX_START_ATTEMPTS);
HiveServer2 server = null;
try {
+ // Cleanup the scratch dir before starting
+ ServerUtils.cleanUpScratchDir(hiveConf);
server = new HiveServer2();
server.init(hiveConf);
server.start();