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 <[email protected]> Authored: Tue Jun 9 13:00:38 2015 -0700 Committer: Jimmy Xiang <[email protected]> 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();
