You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/11/02 11:00:51 UTC
[iotdb] branch issue-4293 created (now bbf1049)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch issue-4293
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at bbf1049 [ISSUE-4293] SessionPool: InterruptedException is not properly handled in synchronized wait()
This branch includes the following new commits:
new bbf1049 [ISSUE-4293] SessionPool: InterruptedException is not properly handled in synchronized wait()
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: [ISSUE-4293] SessionPool: InterruptedException is
not properly handled in synchronized wait()
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch issue-4293
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bbf10499e4c3ffeb27d90500f5c83448fd11a284
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Tue Nov 2 19:00:06 2021 +0800
[ISSUE-4293] SessionPool: InterruptedException is not properly handled in synchronized wait()
---
session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
index f25d1c8..fcf05ea 100644
--- a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
+++ b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
@@ -238,8 +238,7 @@ public class SessionPool {
}
}
} catch (InterruptedException e) {
- logger.error("the SessionPool is damaged", e);
- Thread.currentThread().interrupt();
+ // wake up from this.wait(1000) by this.notify()
}
session = queue.poll();