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 5ea130120ef Active Load: Fix load_active_listing_enable &
load_active_listing_dirs hot load failure (#13491)
5ea130120ef is described below
commit 5ea130120efda5cfb3193558dac0bce95fadf13f
Author: YC27 <[email protected]>
AuthorDate: Thu Sep 12 18:01:55 2024 +0800
Active Load: Fix load_active_listing_enable & load_active_listing_dirs hot
load failure (#13491)
---
.../iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
index 259ee7079c8..ca8760b3e3d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
@@ -108,11 +108,15 @@ public class ActiveLoadDirScanner extends
ActiveLoadScheduledExecutorService {
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
