修复Offset文件目录如果不存在，则创建

921ea272 · ascrutae · f4ab7b53 · 921ea272
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java ...lking/reciever/persistance/RegisterPersistenceThread.java +4 -0

未找到文件。
--- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java
+++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java
@@ -22,6 +22,10 @@ public class RegisterPersistenceThread extends Thread {

    public RegisterPersistenceThread() {
        super("RegisterPersistenceThread");
+        File offsetParentDir = new File(REGISTER_FILE_PARENT_DIRECTORY);
+        if (!offsetParentDir.exists()){
+            offsetParentDir.mkdirs();
+        }
    }

    @Override