You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/04/12 04:34:02 UTC
[iotdb] branch MemoryPoolNPE1.1 created (now 71f25a9243)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch MemoryPoolNPE1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 71f25a9243 Fix MemoryPool free NPE
This branch includes the following new commits:
new 71f25a9243 Fix MemoryPool free NPE
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Fix MemoryPool free NPE
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch MemoryPoolNPE1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 71f25a9243985216e60d55021398ce6bac4e51f8
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Apr 12 12:30:23 2023 +0800
Fix MemoryPool free NPE
---
.../org/apache/iotdb/db/mpp/execution/exchange/sink/SinkChannel.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/SinkChannel.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/SinkChannel.java
index 356bfff296..af52f610fa 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/SinkChannel.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/SinkChannel.java
@@ -138,7 +138,7 @@ public class SinkChannel implements ISinkChannel {
localFragmentInstanceId.queryId,
localFragmentInstanceId.fragmentId,
localFragmentInstanceId.instanceId);
- this.bufferRetainedSizeInBytes = DEFAULT_MAX_TSBLOCK_SIZE_IN_BYTES;
+ this.bufferRetainedSizeInBytes = 0;
this.currentTsBlockSize = DEFAULT_MAX_TSBLOCK_SIZE_IN_BYTES;
}
@@ -389,6 +389,7 @@ public class SinkChannel implements ISinkChannel {
// the handle is created, so we use DEFAULT here. It is ok to use DEFAULT here because
// at first this SinkChannel has not reserved memory.
.left;
+ this.bufferRetainedSizeInBytes = DEFAULT_MAX_TSBLOCK_SIZE_IN_BYTES;
}
@Override