fix lock path error

CalvinKirs · Sep 19, 2023 · c80bf87 · c80bf87
1 parent 760c14f
commit c80bf87
Showing 1 changed file with 8 additions and 11 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/DorisFE.java b/fe/fe-core/src/main/java/org/apache/doris/DorisFE.java
@@ -70,7 +70,7 @@ public class DorisFE {
     public static final String PID_DIR = System.getenv("PID_DIR");
 
 
-    private static final String LOCK_FILE_PATH = Config.meta_dir + "/process.lock";
+    private static String LOCK_FILE_PATH;
     private static FileChannel processLockFileChannel;
     private static FileLock processFileLock;
 
@@ -95,12 +95,6 @@ public static void start(String dorisHomeDir, String pidDir, String[] args, Star
             System.err.println("env PID_DIR is not set.");
             return;
         }
-        try {
-            tryLockProcess();
-        } catch (Exception e) {
-            LOG.error("start doris failed.", e);
-            System.exit(-1);
-        }
 
         CommandLineOptions cmdLineOpts = parseArgs(args);
 
@@ -116,7 +110,13 @@ public static void start(String dorisHomeDir, String pidDir, String[] args, Star
             // Must init custom config after init config, separately.
             // Because the path of custom config file is defined in fe.conf
             config.initCustom(Config.custom_config_dir + "/fe_custom.conf");
-
+            LOCK_FILE_PATH = Config.meta_dir + "/process.lock";
+            try {
+                tryLockProcess();
+            } catch (Exception e) {
+                LOG.error("start doris failed.", e);
+                System.exit(-1);
+            }
             LdapConfig ldapConfig = new LdapConfig();
             if (new File(dorisHomeDir + "/conf/ldap.conf").exists()) {
                 ldapConfig.init(dorisHomeDir + "/conf/ldap.conf");
@@ -430,9 +430,6 @@ private static boolean createAndLockPidFile(String pidFilePath) throws IOExcepti
      * that only one FE process can occupy a metadata directory, and other processes will fail to start.
      */
     private static void tryLockProcess() {
-        if (null == System.getenv("DORIS_HOME")) {
-            return;
-        }
         try {
             processLockFileChannel = FileChannel.open(new File(LOCK_FILE_PATH).toPath(), StandardOpenOption.WRITE,
                     StandardOpenOption.CREATE);