[iotdb] branch master updated: Pipe: fix missing `pipeReceiverFileDir` update after updating `systemDir` during conf initialization (#11318)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 15824d9a292 Pipe: fix missing `pipeReceiverFileDir` update after 
updating `systemDir` during conf initialization (#11318)
15824d9a292 is described below

commit 15824d9a29299020baf87dd648aa100b01ec4b1d
Author: V_Galaxy <dyc1904821...@gmail.com>
AuthorDate: Mon Oct 16 19:50:25 2023 +0800

    Pipe: fix missing `pipeReceiverFileDir` update after updating `systemDir` 
during conf initialization (#11318)
---
 .../src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java      | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index ac016e7a878..e5594f85f81 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -61,6 +61,7 @@ import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Objects;
 import java.util.Properties;
 import java.util.concurrent.TimeUnit;
 import java.util.regex.Pattern;
@@ -1079,8 +1080,8 @@ public class IoTDBConfig {
   private double maxMemoryRatioForQueue = 0.6;
 
   /** Pipe related */
-  private String pipeReceiverFileDir =
-      systemDir + File.separator + "pipe" + File.separator + "receiver";
+  /** initialized as null, updated based on the latest `systemDir` during 
querying */
+  private String pipeReceiverFileDir = null;
 
   /** Resource control */
   private boolean quotaEnable = false;
@@ -3712,7 +3713,9 @@ public class IoTDBConfig {
   }
 
   public String getPipeReceiverFileDir() {
-    return pipeReceiverFileDir;
+    return Objects.isNull(this.pipeReceiverFileDir)
+        ? (systemDir + File.separator + "pipe" + File.separator + "receiver")
+        : this.pipeReceiverFileDir;
   }
 
   public boolean isQuotaEnable() {