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

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


The following commit(s) were added to refs/heads/rel/0.9 by this push:
     new 72e8be8  fix JobFileManager check isCLosed
72e8be8 is described below

commit 72e8be87243b195817c747c95d7f6f2fb5b35b0e
Author: qiaojialin <[email protected]>
AuthorDate: Thu Jul 16 16:17:17 2020 +0800

    fix JobFileManager check isCLosed
---
 .../main/java/org/apache/iotdb/db/query/control/JobFileManager.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 @@ public class JobFileManager {
    * 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);

Reply via email to