[IOTDB-5799] [pool-11-IoTDB-ConfigNodeRPC-Processor-1] ERROR o.a.t.ProcessFunction:47 - Internal error processing getAllPipeInfo java.lang.UnsupportedOperationException: Not implemented yet

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.2.0
• Component/s: mpp-cluster
• Assignee: Steve Yurong Su
• Reporter: 刘珍
• Created: 20/Apr/23 02:32
• Updated: 20/Apr/23 03:37

Description

版本： iotdb master 0419_c97c0dc
干净环境，启动集群 confignode 报错 ，需处理(启动成功，读写都是正常的）
2023-04-20 10:16:55,952 [pool-11-IoTDB-ConfigNodeRPC-Processor-11] ERROR o.a.t.ProcessFunction:47 - Internal error processing getAllPipeInfo
java.lang.UnsupportedOperationException: Not implemented yet
at org.apache.iotdb.confignode.manager.pipe.PipeTaskCoordinator.showPipes(PipeTaskCoordinator.java:67)
at org.apache.iotdb.confignode.manager.ConfigManager.getAllPipeInfo(ConfigManager.java:1603)
at org.apache.iotdb.confignode.service.thrift.ConfigNodeRPCServiceProcessor.getAllPipeInfo(ConfigNodeRPCServiceProcessor.java:902)
at org.apache.iotdb.confignode.rpc.thrift.IConfigNodeRPCService$Processor$getAllPipeInfo.getResult(IConfigNodeRPCService.java:8783)
at org.apache.iotdb.confignode.rpc.thrift.IConfigNodeRPCService$Processor$getAllPipeInfo.getResult(IConfigNodeRPCService.java:8763)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38)
at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:248)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)

datanode 错误日志：
2023-04-20 10:16:34,538 [main] ERROR o.a.i.d.s.c.ClusterSyncInfoFetcher:122 - Get AllPipeInfos error because Error in calling method getAllPipeInfo, because: Fail to connect to any config node. Please check status of ConfigNodes
org.apache.thrift.TException: Error in calling method getAllPipeInfo, because: Fail to connect to any config node. Please check status of ConfigNodes
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:57)
at org.apache.iotdb.db.client.ConfigNodeClient$$EnhancerByCGLIB$$c8b4afb7.getAllPipeInfo(<generated>)
at org.apache.iotdb.db.sync.common.ClusterSyncInfoFetcher.getAllPipeInfos(ClusterSyncInfoFetcher.java:117)
at org.apache.iotdb.db.sync.SyncService.recover(SyncService.java:496)
at org.apache.iotdb.db.sync.SyncService.start(SyncService.java:452)
at org.apache.iotdb.commons.service.RegisterManager.register(RegisterManager.java:51)
at org.apache.iotdb.db.service.DataNode.setUp(DataNode.java:539)
at org.apache.iotdb.db.service.DataNode.active(DataNode.java:471)
at org.apache.iotdb.db.service.DataNode.doAddNode(DataNode.java:175)
at org.apache.iotdb.db.service.DataNodeServerCommandLine.run(DataNodeServerCommandLine.java:81)
at org.apache.iotdb.commons.ServerCommandLine.doMain(ServerCommandLine.java:58)
at org.apache.iotdb.db.service.DataNode.main(DataNode.java:151)
Caused by: org.apache.thrift.TException: Fail to connect to any config node. Please check status of ConfigNodes
at org.apache.iotdb.db.client.ConfigNodeClient.getAllPipeInfo(ConfigNodeClient.java:1856)
at org.apache.iotdb.db.client.ConfigNodeClient$$EnhancerByCGLIB$$c8b4afb7.CGLIB$getAllPipeInfo$83(<generated>)
at org.apache.iotdb.db.client.ConfigNodeClient$$EnhancerByCGLIB$$c8b4afb7$$FastClassByCGLIB$$faee4a8d.invoke(<generated>)
at net.sf.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.intercept(SyncThriftClientWithErrorHandler.java:53)
... 11 common frames omitted