[iotdb] branch master updated: [IOTDB-3945] Fix TTL doesn't take effect bug in mpp

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 6d3c0cc4d0 [IOTDB-3945] Fix TTL doesn't take effect bug in mpp
6d3c0cc4d0 is described below

commit 6d3c0cc4d06c077ffc93a5290ff70f08efb61783
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Wed Jul 27 09:09:36 2022 +0800

    [IOTDB-3945] Fix TTL doesn't take effect bug in mpp
---
 .../iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
index 254693e7b9..af6b72e47a 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
@@ -79,8 +79,8 @@ public class SeriesScanUtil {
    *
    * valueFilter is pushed down to non-overlapped page only
    */
-  private final Filter timeFilter;
-  private final Filter valueFilter;
+  private Filter timeFilter;
+  private Filter valueFilter;
 
   private QueryDataSource dataSource;
 
@@ -161,6 +161,10 @@ public class SeriesScanUtil {
   public void initQueryDataSource(QueryDataSource dataSource) {
     QueryUtils.fillOrderIndexes(dataSource, seriesPath.getDevice(), 
orderUtils.getAscending());
     this.dataSource = dataSource;
+    this.timeFilter = dataSource.updateFilterUsingTTL(timeFilter);
+    if (this.valueFilter != null) {
+      this.valueFilter = dataSource.updateFilterUsingTTL(valueFilter);
+    }
     orderUtils.setCurSeqFileIndex(dataSource);
   }