You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2025/12/04 14:42:04 UTC
(iotdb) 01/01: fix
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch fix_wal_create_error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ca51b0d2ae78933ad2e13a9883b4e737e858f59b
Author: OneSizeFitsQuorum <ta...@apache.org>
AuthorDate: Thu Dec 4 22:41:41 2025 +0800
fix
Signed-off-by: OneSizeFitsQuorum <ta...@apache.org>
---
.../dataregion/wal/allocation/AbstractNodeAllocationStrategy.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
index 119f262ea66..ade9fad1356 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
@@ -57,6 +57,10 @@ public abstract class AbstractNodeAllocationStrategy implements NodeAllocationSt
protected IWALNode createWALNode(String identifier) {
try {
+ if (folderManager == null) {
+ folderManager = new FolderManager(
+ Arrays.asList(commonConfig.getWalDirs()), DirectoryStrategyType.SEQUENCE_STRATEGY);
+ }
return folderManager.getNextWithRetry(
folder -> new WALNode(identifier, folder + File.separator + identifier));
} catch (DiskSpaceInsufficientException e) {