commit 72e8be87243b195817c747c95d7f6f2fb5b35b0e
author qiaojialin <646274302@qq.com> Thu Jul 16 16:17:17 2020 +0800
committer qiaojialin <646274302@qq.com> Thu Jul 16 16:17:17 2020 +0800
tree 9ca0fef53ad810b8543e19194567271cb7519922
parent 6f1d44a64343ae038ce642776ccff9217f89a453

fix JobFileManager check isCLosed

server/src/main/java/org/apache/iotdb/db/query/control/JobFileManager.java

diff --git a/server/src/main/java/org/apache/iotdb/db/query/control/JobFileManager.java b/server/src/main/java/org/apache/iotdb/db/query/control/JobFileManager.java
index 2e3b2a1..ab1daa3 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/control/JobFileManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/control/JobFileManager.java
@@ -110,8 +110,7 @@
    * must not return null.

    */

   void addFilePathToMap(long jobId, TsFileResource tsFile, boolean isClosed) {

-    Map<Long, Set<TsFileResource>> pathMap = isClosed ? unsealedFilePathsMap :

-        sealedFilePathsMap;

+    Map<Long, Set<TsFileResource>> pathMap = isClosed ? sealedFilePathsMap : unsealedFilePathsMap;

     //TODO this is not an atomic operation, is there concurrent problem?

     if (!pathMap.get(jobId).contains(tsFile)) {

       pathMap.get(jobId).add(tsFile);