[incubator-iotdb] branch aggregate updated: fix bug of QueryTokenManager

[suyue]

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

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


The following commit(s) were added to refs/heads/aggregate by this push:
     new c709649  fix bug of QueryTokenManager
c709649 is described below

commit c709649243c994adc24c1802c5e25fd0f7f0fe80
Author: suyue <2335813...@qq.com>
AuthorDate: Fri Mar 29 14:08:35 2019 +0800

    fix bug of QueryTokenManager
---
 .../main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java 
b/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java
index 50a2cb4..b6e8bcb 100644
--- 
a/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java
+++ 
b/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java
@@ -161,7 +161,7 @@ public class QueryTokenManager {
   }
 
   private void putQueryTokenForCurrentRequestThread(long jobId, String 
deviceId, int queryToken) {
-    queryTokensMap.get(jobId).computeIfPresent(deviceId, (x, y) -> new 
ArrayList<>()).add(queryToken);
+    queryTokensMap.get(jobId).computeIfAbsent(deviceId, x -> new 
ArrayList<>()).add(queryToken);
   }
 
   private static class QueryTokenManagerHelper {