You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@iotdb.apache.org by "suchenglong (Jira)" <ji...@apache.org> on 2022/08/29 10:07:00 UTC
[jira] [Created] (IOTDB-4268) SessionPool.deleteData annother error
suchenglong created IOTDB-4268:
----------------------------------
Summary: SessionPool.deleteData annother error
Key: IOTDB-4268
URL: https://issues.apache.org/jira/browse/IOTDB-4268
Project: Apache IoTDB
Issue Type: Bug
Affects Versions: 0.14.0-SNAPSHOT
Reporter: suchenglong
Assignee: Haonan Hou
Attachments: image-2022-08-29-18-02-37-377.png
环境：集群版，3configNode,3DataNode
!image-2022-08-29-18-02-37-377.png!
问题： 执行deleteData时，客户端报如下错误，
# 执行多次依旧报下面的问题，此时节点都是好的，并无异常(单独可连接)
# 集群模式下，即使1台机器挂了，是不是也不应该直接返回错误，应该执行成功才对。
org.apache.iotdb.rpc.StatementExecutionException: 310: can't connect to node {}TEndPoint(ip:192.168.1.218, port:9003)
at org.apache.iotdb.rpc.RpcUtils.verifySuccess(RpcUtils.java:96) ~[service-rpc-0.14.0-SNAPSHOT.jar:0.14.0-SNAPSHOT]
at org.apache.iotdb.session.SessionConnection.deleteData(SessionConnection.java:653) ~[iotdb-session-0.14.0-SNAPSHOT.jar:0.14.0-SNAPSHOT]
at org.apache.iotdb.session.Session.deleteData(Session.java:1914) ~[iotdb-session-0.14.0-SNAPSHOT.jar:0.14.0-SNAPSHOT]
at org.apache.iotdb.session.pool.SessionPool.deleteData(SessionPool.java:1532) ~[iotdb-session-0.14.0-SNAPSHOT.jar:0.14.0-SNAPSHOT]
at org.cisdi.api.SessionApiWithAutoCreateWithVersion0140P1.deleteRecords(SessionApiWithAutoCreateWithVersion0140P1.java:550) [classes/:na]
at org.cisdi.api.SessionApiWithAutoCreateWithVersion0140P1.doClose(SessionApiWithAutoCreateWithVersion0140P1.java:261) [classes/:na]
at
org.cisdi.api.SessionApiWithAutoCreateWithVersion0140P1.main(SessionApiWithAutoCreateWithVersion0140P1.java:155) [classes/:na]
服务端日志为：
2022-08-29 17:57:39,841 [20220829_095733_02369_2.4.0-49] ERROR o.a.i.d.m.p.s.FragmentInstanceDispatcherImpl:190 - can't connect to node TEndPoint(ip:192.168.1.218, port:9003)
org.apache.thrift.TException: Error in calling method sendPlanNode
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:94)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.sendPlanNode(<generated>)
at org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchRemote(FragmentInstanceDispatcherImpl.java:177)
at org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchOneInstance(FragmentInstanceDispatcherImpl.java:145)
at org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchWriteSync(FragmentInstanceDispatcherImpl.java:125)
at org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatch(FragmentInstanceDispatcherImpl.java:96)
at org.apache.iotdb.db.mpp.plan.scheduler.ClusterScheduler.start(ClusterScheduler.java:101)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.schedule(QueryExecution.java:255)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.start(QueryExecution.java:182)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.retry(QueryExecution.java:209)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.getStatus(QueryExecution.java:423)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.retry(QueryExecution.java:210)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.getStatus(QueryExecution.java:423)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.retry(QueryExecution.java:210)
at org.apache.iotdb.db.mpp.plan.execution.QueryExecution.getStatus(QueryExecution.java:423)
at org.apache.iotdb.db.mpp.plan.Coordinator.execute(Coordinator.java:148)
at org.apache.iotdb.db.mpp.plan.Coordinator.execute(Coordinator.java:160)
at org.apache.iotdb.db.service.thrift.impl.ClientRPCServiceImpl.deleteData(ClientRPCServiceImpl.java:1124)
at org.apache.iotdb.service.rpc.thrift.IClientRPCService$Processor$deleteData.getResult(IClientRPCService.java:3837)
at org.apache.iotdb.service.rpc.thrift.IClientRPCService$Processor$deleteData.getResult(IClientRPCService.java:3817)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38)
at org.apache.iotdb.db.service.thrift.ProcessorWithMetrics.process(ProcessorWithMetrics.java:64)
at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:248)
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: org.apache.thrift.TException: Error in calling method recv_sendPlanNode
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:94)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.recv_sendPlanNode(<generated>)
at org.apache.iotdb.mpp.rpc.thrift.IDataNodeRPCService$Client.sendPlanNode(IDataNodeRPCService.java:328)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.CGLIB$sendPlanNode$80(<generated>)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852$$FastClassByCGLIB$$91b40819.invoke(<generated>)
at net.sf.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:55)
... 25 common frames omitted
Caused by: org.apache.thrift.TException: Error in calling method receiveBase
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:94)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.receiveBase(<generated>)
at org.apache.iotdb.mpp.rpc.thrift.IDataNodeRPCService$Client.recv_sendPlanNode(IDataNodeRPCService.java:341)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.CGLIB$recv_sendPlanNode$11(<generated>)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852$$FastClassByCGLIB$$91b40819.invoke(<generated>)
at net.sf.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:55)
... 31 common frames omitted
Caused by: org.apache.thrift.TApplicationException: Internal error processing sendPlanNode
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852.CGLIB$receiveBase$102(<generated>)
at org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient$$EnhancerByCGLIB$$9c08f852$$FastClassByCGLIB$$91b40819.invoke(<generated>)
at net.sf.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:55)
... 37 common frames omitted
--
This message was sent by Atlassian Jira
(v8.20.10#820010)