From 199c972968118a406fe98fc617ebc95acbb9a3c8 Mon Sep 17 00:00:00 2001 From: ligang Date: Thu, 23 May 2019 17:38:48 +0800 Subject: [PATCH] remove init basepath --- .../java/cn/escheduler/common/utils/HadoopUtils.java | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/escheduler-common/src/main/java/cn/escheduler/common/utils/HadoopUtils.java b/escheduler-common/src/main/java/cn/escheduler/common/utils/HadoopUtils.java index b3ba7f5b8..bba9e610f 100644 --- a/escheduler-common/src/main/java/cn/escheduler/common/utils/HadoopUtils.java +++ b/escheduler-common/src/main/java/cn/escheduler/common/utils/HadoopUtils.java @@ -100,7 +100,6 @@ public class HadoopUtils implements Closeable { logger.info("appAddress : {}", appAddress); } configuration.set(Constants.YARN_APPLICATION_STATUS_ADDRESS, appAddress); - initBasePath(); } catch (Exception e) { logger.error(e.getMessage(), e); } @@ -110,17 +109,6 @@ public class HadoopUtils implements Closeable { } } - /** - * init data.store2hdfs.basepath in common.properties - * @throws IOException - */ - private void initBasePath() throws IOException { - Path path = new Path(getString(DATA_STORE_2_HDFS_BASEPATH)); - if( !fs.exists(path) ){ - fs.mkdirs(path); - } - } - /** * @return Configuration */ -- GitLab