This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new d2622f6cce3 [To dev/1.3] Load: Add check for reset memory size to 0 in
LoadTsFileMemoryManager (#16940) #16942
d2622f6cce3 is described below
commit d2622f6cce3353e6b791a1ccfb13b7ca830faf55
Author: Zhenyu Luo <[email protected]>
AuthorDate: Mon Dec 22 19:26:14 2025 +0800
[To dev/1.3] Load: Add check for reset memory size to 0 in
LoadTsFileMemoryManager (#16940) #16942
(cherry picked from commit 302864ae1ced9bf495812bbc976fba583f675630)
---
.../db/storageengine/load/memory/LoadTsFileMemoryManager.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
index a3e349678a5..4b08064bb9c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
@@ -82,6 +82,10 @@ public class LoadTsFileMemoryManager {
}
public synchronized void releaseToQuery(final long sizeInBytes) {
+ if (sizeInBytes <= 0) {
+ throw new IllegalArgumentException(
+ String.format("Load: Invalid memory size %d bytes, must be
positive", sizeInBytes));
+ }
if (usedMemorySizeInBytes.get() < sizeInBytes) {
LOGGER.error(
"Load: Attempting to release more memory ({}) than allocated ({})",
@@ -96,6 +100,10 @@ public class LoadTsFileMemoryManager {
public synchronized LoadTsFileMemoryBlock allocateMemoryBlock(long
sizeInBytes)
throws LoadRuntimeOutOfMemoryException {
+ if (sizeInBytes <= 0) {
+ throw new IllegalArgumentException(
+ String.format("Load: Invalid memory size %d bytes, must be
positive", sizeInBytes));
+ }
try {
forceAllocateFromQuery(sizeInBytes);
if (LOGGER.isDebugEnabled()) {