[incubator-iotdb] branch cluster_read updated: fix a bug

[dope]

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

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


The following commit(s) were added to refs/heads/cluster_read by this push:
     new 11ada64  fix a bug
11ada64 is described below

commit 11ada64527b582ca892df54e966e6933e6728bc1
Author: MyXOF <xuyi556...@163.com>
AuthorDate: Wed Apr 24 16:47:38 2019 +0800

    fix a bug
---
 .../org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
index 039bf75..c5e563b 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
@@ -278,6 +278,7 @@ public class RaftNodeAsClientManager {
                 }, TASK_TIMEOUT_MS);
       } catch (RemotingException | InterruptedException e) {
         LOGGER.error(e.getMessage());
+        boltClientService.disconnect(leader.getEndpoint());
         qpTask.setTaskState(TaskState.EXCEPTION);
         releaseClient(RaftNodeAsClient.this);
         qpTask.run(null);