[iotdb] branch issue-4293-0.12 created (now 87c80ac)

[ro...@apache.org]

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

rong pushed a change to branch issue-4293-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


      at 87c80ac  [ISSUE-4293] SessionPool: InterruptedException is not properly handled in synchronized wait()

This branch includes the following new commits:

     new 87c80ac  [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()

[ro...@apache.org]

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

rong pushed a commit to branch issue-4293-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 87c80ac41f43699d61d38307f30286f5f7910ae6
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Tue Nov 2 18:47:18 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 3afdbe7..98b70c8 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();