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);