新增处理云南文件同步中的文件存储层级目录问题

src/main/java/com/ihooyah/flume/sink/YunnanFileSink.java

@@ -18,6 +18,7 @@ import java.util.Map;
 
 /**
  * 云南项目读取文件到指定目录
+ * 文件名请重命名   将存储路径放置于文件名中按照逗号隔开
  */
 public class YunnanFileSink extends AbstractSink implements Configurable, BatchSizeSupported {
 
@@ -81,8 +82,14 @@ public class YunnanFileSink extends AbstractSink implements Configurable, BatchS
             return;
         }
 
-        fileName=fileName.replaceAll(",","\\/");
+        fileName=fileName.replaceAll(",,",",").replaceAll(",","\\/");
         String uploadDir="/"+fileName;
+        String dir=uploadDir.substring(0,uploadDir.lastIndexOf("/"));
+        logger.info("uploadDir:"+uploadDir+" dir:"+dir);
+        File isDir=new File(dir);
+        if (!isDir.exists()){
+            isDir.mkdirs();
+        }
         logger.info("deal data numbers: {}", eventList.size());
         File localFile = new File(uploadDir);
         FileOutputStream fos = new FileOutputStream(localFile);