[incubator-iotdb] branch cluster_read updated: remove disconnect function

[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 ac17966  remove disconnect function
ac17966 is described below

commit ac17966077e052f5424a7b29ecae6eef9259b6ba
Author: MyXOF <xuyi556...@163.com>
AuthorDate: Wed Apr 24 16:56:02 2019 +0800

    remove disconnect function
---
 .../apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java   | 4 ----
 1 file changed, 4 deletions(-)

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 c5e563b..9e99d7f 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
@@ -257,7 +257,6 @@ public class RaftNodeAsClientManager {
                   @Override
                   public void onResponse(Object result) {
                     BasicResponse response = (BasicResponse) result;
-                    boltClientService.disconnect(leader.getEndpoint());
                     releaseClient(RaftNodeAsClient.this);
                     qpTask.run(response);
                   }
@@ -266,7 +265,6 @@ public class RaftNodeAsClientManager {
                   public void onException(Throwable e) {
                     LOGGER.error("Bolt rpc client occurs errors when handling 
Request", e);
                     qpTask.setTaskState(TaskState.EXCEPTION);
-                    boltClientService.disconnect(leader.getEndpoint());
                     releaseClient(RaftNodeAsClient.this);
                     qpTask.run(null);
                   }
@@ -278,7 +276,6 @@ 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);
@@ -295,7 +292,6 @@ public class RaftNodeAsClientManager {
       } catch (RemotingException | InterruptedException e) {
         return new QueryTask(null, TaskState.EXCEPTION);
       } finally {
-        boltClientService.disconnect(peerId.getEndpoint());
         releaseClient(RaftNodeAsClient.this);
       }
     }