You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@iotdb.apache.org by "Jialin Qiao (Jira)" <ji...@apache.org> on 2022/07/01 02:03:00 UTC
[jira] [Assigned] (IOTDB-3272) [ error message ] Borrow client error when the target DataNode is down
[ https://issues.apache.org/jira/browse/IOTDB-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jialin Qiao reassigned IOTDB-3272:
----------------------------------
Assignee: Yuan Tian
> [ error message ] Borrow client error when the target DataNode is down
> ----------------------------------------------------------------------
>
> Key: IOTDB-3272
> URL: https://issues.apache.org/jira/browse/IOTDB-3272
> Project: Apache IoTDB
> Issue Type: Bug
> Components: mpp-cluster
> Affects Versions: 0.14.0-SNAPSHOT
> Reporter: 刘珍
> Assignee: Yuan Tian
> Priority: Minor
> Attachments: image-2022-05-24-10-34-58-400.png
>
>
> master_0523_51e9703
> data_replication_factor=1
> 3confignode，3datanode。
> 停止node1的datanode，cli在node2 查询node1上的数据，{color:#DE350B}*报错信息不明确*{color}：
> !image-2022-05-24-10-34-58-400.png!
> error code: TSStatus(code:411, message:org.apache.iotdb.db.exception.mpp.FragmentInstanceDispatchException: java.io.IOException: {color:#DE350B}*Borrow client from pool for node TEndPoint(ip:192.168.130.3, port:9003) failed.)*{color}
> *datanode的log_error.log*
> 2022-05-24 10:27:25,667 [pool-17-IoTDB-MPPCoordinator-3] ERROR o.a.i.d.m.p.s.SimpleQueryTerminator:78 - can't connect to node TEndPoint(ip:192.168.130.3, port:9003)
> java.io.IOException: {color:#DE350B}*Borrow client from pool for node TEndPoint(ip:192.168.130.3, port:9003) failed.*{color}
> at org.apache.iotdb.commons.client.ClientManager.borrowClient(ClientManager.java:61)
> at org.apache.iotdb.db.mpp.plan.scheduler.SimpleQueryTerminator.lambda$terminate$0(SimpleQueryTerminator.java:74)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused)
> at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:235)
> at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:220)
> at net.sf.cglib.proxy.Enhancer.createUsingReflection(Enhancer.java:639)
> at net.sf.cglib.proxy.Enhancer.firstInstance(Enhancer.java:538)
> at net.sf.cglib.core.AbstractClassGenerator.create(AbstractClassGenerator.java:231)
> at net.sf.cglib.proxy.Enhancer.createHelper(Enhancer.java:377)
> at net.sf.cglib.proxy.Enhancer.create(Enhancer.java:304)
> at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.newErrorHandler(SyncThriftClientWithErrorHandler.java:48)
> at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$Factory.makeObject(SyncDataNodeInternalServiceClient.java:127)
> at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$Factory.makeObject(SyncDataNodeInternalServiceClient.java:105)
> at org.apache.commons.pool2.impl.GenericKeyedObjectPool.create(GenericKeyedObjectPool.java:780)
> at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:439)
> at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:350)
> at org.apache.iotdb.commons.client.ClientManager.borrowClient(ClientManager.java:50)
> ... 5 common frames omitted
> Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused (Connection refused)
> at org.apache.thrift.transport.TSocket.open(TSocket.java:243)
> at org.apache.iotdb.rpc.TElasticFramedTransport.open(TElasticFramedTransport.java:91)
> at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient.<init>(SyncDataNodeInternalServiceClient.java:63)
> at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$33430b8f.<init>(<generated>)
> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
> at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:228)
> ... 18 common frames omitted
> Caused by: java.net.ConnectException: Connection refused (Connection refused)
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)
> at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)
> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)
> at java.net.Socket.connect(Socket.java:606)
> at org.apache.thrift.transport.TSocket.open(TSocket.java:238)
> ... 26 common frames omitted
--
This message was sent by Atlassian Jira
(v8.20.10#820010)