[iotdb] branch master updated: [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException: Client has an error!Caused by: java.net.ConnectException: Connection refused (#6049)

[haonan]

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

haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 467243dbd4 [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException: 
Client has an error!Caused by: java.net.ConnectException: Connection refused 
(#6049)
467243dbd4 is described below

commit 467243dbd40172ecee342751a25b92bbfb696123
Author: Potato <txypot...@gmail.com>
AuthorDate: Fri May 27 18:56:23 2022 +0800

    [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException: Client has an 
error!Caused by: java.net.ConnectException: Connection refused (#6049)
---
 .../apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java  | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
index 7590b1661b..62157d6ecb 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
@@ -34,7 +34,6 @@ import org.apache.iotdb.commons.exception.MetadataException;
 import org.apache.iotdb.commons.path.PartialPath;
 import org.apache.iotdb.commons.udf.service.UDFExecutableManager;
 import org.apache.iotdb.commons.udf.service.UDFRegistrationService;
-import org.apache.iotdb.consensus.IConsensus;
 import org.apache.iotdb.consensus.common.Peer;
 import org.apache.iotdb.consensus.common.request.ByteBufferConsensusRequest;
 import org.apache.iotdb.consensus.common.response.ConsensusGenericResponse;
@@ -105,7 +104,6 @@ public class InternalServiceImpl implements 
InternalService.Iface {
   private static final Logger LOGGER = 
LoggerFactory.getLogger(InternalServiceImpl.class);
   private final SchemaEngine schemaEngine = SchemaEngine.getInstance();
   private final StorageEngineV2 storageEngine = StorageEngineV2.getInstance();
-  private final IConsensus consensusImpl = ConsensusImpl.getInstance();
   private final double loadBalanceThreshold = 0.1;
 
   public InternalServiceImpl() {
@@ -203,7 +201,7 @@ public class InternalServiceImpl implements 
InternalService.Iface {
         peers.add(new Peer(schemaRegionId, endpoint));
       }
       ConsensusGenericResponse consensusGenericResponse =
-          consensusImpl.addConsensusGroup(schemaRegionId, peers);
+          ConsensusImpl.getInstance().addConsensusGroup(schemaRegionId, peers);
       if (consensusGenericResponse.isSuccess()) {
         tsStatus = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
       } else {
@@ -241,7 +239,7 @@ public class InternalServiceImpl implements 
InternalService.Iface {
         peers.add(new Peer(dataRegionId, endpoint));
       }
       ConsensusGenericResponse consensusGenericResponse =
-          consensusImpl.addConsensusGroup(dataRegionId, peers);
+          ConsensusImpl.getInstance().addConsensusGroup(dataRegionId, peers);
       if (consensusGenericResponse.isSuccess()) {
         tsStatus = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
       } else {
@@ -353,7 +351,7 @@ public class InternalServiceImpl implements 
InternalService.Iface {
     PlanFragment planFragment = new PlanFragment(planFragmentId, 
deleteRegionNode);
     FragmentInstance fragmentInstance =
         new FragmentInstance(planFragment, fragmentInstanceId, null, 
QueryType.WRITE);
-    return consensusImpl.write(consensusGroupId, fragmentInstance).getStatus();
+    return ConsensusImpl.getInstance().write(consensusGroupId, 
fragmentInstance).getStatus();
   }
 
   @Override