This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch MemoryPoolNPE in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1188c516d61ca6af5f2965b8a31a464ee22858db Author: JackieTien97 <[email protected]> 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 1b027ba2ab..fd11f74990 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; localMemoryManager .getQueryPool() @@ -385,6 +385,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
