This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ShowLatestTimeSeries012 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4a0c2bdbe30c5794c72d5e5dbfcebd649b0e7457 Author: JackieTien97 <[email protected]> AuthorDate: Tue Nov 16 10:28:45 2021 +0800 Update last cache while doing show latest timeseries query --- server/src/main/java/org/apache/iotdb/db/metadata/MTree.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java index 3fc53c8..1058277 100644 --- a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java +++ b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java @@ -103,6 +103,8 @@ public class MTree implements Serializable { private static transient ThreadLocal<Integer> offset = new ThreadLocal<>(); private static transient ThreadLocal<Integer> count = new ThreadLocal<>(); private static transient ThreadLocal<Integer> curOffset = new ThreadLocal<>(); + private static final boolean CACHE_ENABLED = + IoTDBDescriptor.getInstance().getConfig().isLastCacheEnabled(); private MNode root; MTree() { @@ -134,6 +136,9 @@ public class MTree implements Serializable { Long.MAX_VALUE, null); last = lastReader.readLastPoint(); + if (CACHE_ENABLED && last != null && last.getValue() != null) { + node.updateCachedLast(last, false, Long.MIN_VALUE); + } return (last != null ? last.getTimestamp() : Long.MIN_VALUE); } catch (Exception e) { logger.error(
