This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch iotdb-2062 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 529d6a58bd5415024cbce2c815dbcc28b8422f92 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Nov 26 11:10:49 2021 +0800 fix leaks in SingleInputColumnSingleReferenceIntermediateLayer#constructRowSlidingSizeWindowReader() and SingleInputColumnSingleReferenceIntermediateLayer#constructRowSlidingTimeWindowReader() --- .../core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java b/server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java index 3dc3e34..be5d41c 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java +++ b/server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java @@ -144,6 +144,8 @@ public class SingleInputColumnSingleReferenceIntermediateLayer extends Intermedi @Override public void readyForNext() { hasCached = false; + + tvList.setEvictionUpperBound(beginIndex + 1); } @Override @@ -234,6 +236,8 @@ public class SingleInputColumnSingleReferenceIntermediateLayer extends Intermedi public void readyForNext() { hasCached = false; nextWindowTimeBegin += slidingStep; + + tvList.setEvictionUpperBound(nextIndexBegin + 1); } @Override
