add initBasePath

escheduler-common/src/main/java/cn/escheduler/common/utils/HadoopUtils.java

@@ -100,6 +100,7 @@ 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);
                     }
@@ -109,6 +110,17 @@ 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
      */