[iotdb] branch ChunkCacheBug updated: fix potential bug

[jackietien]

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

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


The following commit(s) were added to refs/heads/ChunkCacheBug by this push:
     new b4b8a31  fix potential bug
b4b8a31 is described below

commit b4b8a31499225e2dadefd9c77c69f561801de807
Author: JackieTien97 <jackiet...@foxmail.com>
AuthorDate: Mon May 31 09:47:51 2021 +0800

    fix potential bug
---
 .../iotdb/db/engine/cache/TimeSeriesMetadataCache.java  | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCache.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCache.java
index e10a6bb..30f3ded 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCache.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCache.java
@@ -198,14 +198,15 @@ public class TimeSeriesMetadataCache {
           List<TimeseriesMetadata> timeSeriesMetadataList =
               reader.readTimeseriesMetadata(path, allSensors);
           // put TimeSeriesMetadata of all sensors used in this query into 
cache
-          timeSeriesMetadataList.forEach(
-              metadata -> {
-                TimeSeriesMetadataCacheKey k =
-                    new TimeSeriesMetadataCacheKey(
-                        key.filePath, key.device, metadata.getMeasurementId());
-                lruCache.put(k, metadata);
-              });
-          timeseriesMetadata = lruCache.getIfPresent(key);
+          for (TimeseriesMetadata metadata : timeSeriesMetadataList) {
+            TimeSeriesMetadataCacheKey k =
+                new TimeSeriesMetadataCacheKey(
+                    key.filePath, key.device, metadata.getMeasurementId());
+            lruCache.put(k, metadata);
+            if (metadata.getMeasurementId().equals(key.measurement)) {
+              timeseriesMetadata = metadata;
+            }
+          }
         }
       }
     }