You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/11/26 03:19:36 UTC
[iotdb] 01/02: fix leaks in SingleInputColumnSingleReferenceIntermediateLayer#constructRowSlidingSizeWindowReader() and SingleInputColumnSingleReferenceIntermediateLayer#constructRowSlidingTimeWindowReader()
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 <ro...@apache.org>
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