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

rong pushed a commit to branch fix-multi-load-dirs
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 26f6cda2ba8a00a4dbba34b55aca1b3b686fa129
Author: Steve Yurong Su <[email protected]>
AuthorDate: Thu Jul 11 15:42:43 2024 +0800

    Load: Fix multi dir strategy applying on loadTsFileDirs
---
 .../src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java  | 12 +++++++++---
 1 file changed, 9 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 05539f9fab1..e9ff3a9b79a 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
@@ -1475,10 +1475,16 @@ public class IoTDBConfig {
   }
 
   public void formulateLoadTsFileDirs(String[][] tierDataDirs) {
-    final String[] newLoadTsFileDirs = new String[tierDataDirs.length];
-    for (int i = 0; i < tierDataDirs.length; i++) {
+    if (tierDataDirs.length < 1) {
+      logger.warn("No data directory is set. loadTsFileDirs is kept as the 
default value.");
+      return;
+    }
+
+    final String[] firstTierDataDirs = tierDataDirs[0];
+    final String[] newLoadTsFileDirs = new String[firstTierDataDirs.length];
+    for (int i = 0; i < firstTierDataDirs.length; i++) {
       newLoadTsFileDirs[i] =
-          tierDataDirs[i][0] + File.separator + 
IoTDBConstant.LOAD_TSFILE_FOLDER_NAME;
+          firstTierDataDirs[i] + File.separator + 
IoTDBConstant.LOAD_TSFILE_FOLDER_NAME;
     }
 
     // Update loadTsFileDirs after all newLoadTsFileDirs are generated,

Reply via email to