[incubator-iotdb] branch feature_async_close_tsfile updated: fix unsealed tsfile processor query bug

[qi...@apache.org]

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

qiaojialin pushed a commit to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
     new c0c6bcf  fix unsealed tsfile processor query bug
c0c6bcf is described below

commit c0c6bcf323ea8627830df6fa1847d21bbcddba9e
Author: qiaojialin <64...@qq.com>
AuthorDate: Sun Jun 23 14:54:57 2019 +0800

    fix unsealed tsfile processor query bug
---
 .../apache/iotdb/db/engine/filenodeV2/UnsealedTsFileProcessorV2.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/UnsealedTsFileProcessorV2.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/UnsealedTsFileProcessorV2.java
index a97ac80..5b27226 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/UnsealedTsFileProcessorV2.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/UnsealedTsFileProcessorV2.java
@@ -372,10 +372,13 @@ public class UnsealedTsFileProcessorV2 {
     try {
       MemSeriesLazyMerger memSeriesLazyMerger = new MemSeriesLazyMerger();
       for (IMemTable flushingMemTable : flushingMemTables) {
+        if (!flushingMemTable.isManagedByMemPool()) {
+          continue;
+        }
         memSeriesLazyMerger
             .addMemSeries(flushingMemTable.query(deviceId, measurementId, dataType, props));
       }
-      if (workMemTable != null && workMemTable.isManagedByMemPool()) {
+      if (workMemTable != null) {
         memSeriesLazyMerger
             .addMemSeries(workMemTable.query(deviceId, measurementId, dataType, props));
       }