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 <[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 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
