Active Load: Fix load_active_listing_enable & load_active_listing_dir…

…s hot load failure (apache#13491)
Caideyipi · Sep 12, 2024 · 5ea1301 · 5ea1301
1 parent 13097fe
commit 5ea1301
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java b/...ode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
@@ -108,11 +108,15 @@ private void hotReloadActiveLoadDirs() {
         if (IOTDB_CONFIG.getLoadActiveListeningDirs() != listeningDirsConfig.get()) {
           synchronized (this) {
             if (IOTDB_CONFIG.getLoadActiveListeningDirs() != listeningDirsConfig.get()) {
+              listeningDirs.clear();
+
               listeningDirsConfig.set(IOTDB_CONFIG.getLoadActiveListeningDirs());
               listeningDirs.addAll(Arrays.asList(IOTDB_CONFIG.getLoadActiveListeningDirs()));
             }
           }
         }
+      } else {
+        listeningDirs.clear();
       }
       // Hot reload active load listening dir for pipe data sync
       // Active load is always enabled for pipe data sync