刘珍 created IOTDB-3449: ------------------------- Summary: [ COUNT query ] executeStatement failed. error code: TSStatus(code:411, message:Fragment cannot be dispatched) Key: IOTDB-3449 URL: https://issues.apache.org/jira/browse/IOTDB-3449 Project: Apache IoTDB Issue Type: Bug Components: mpp-cluster Affects Versions: 0.14.0-SNAPSHOT Reporter: 刘珍 Assignee: Yuan Tian Attachments: 101-200.sh, config.properties
master_0610_3766327 3节点3副本(COUNT大写), select {color:red}COUNT{color}(s_4) from root.**; Msg: 500: [INTERNAL_SERVER_ERROR(500)] Exception occurred: "select COUNT(s_4) from root.**". executeStatement failed. error code: TSStatus(code:411, message:Fragment cannot be dispatched) 2022-06-10 13:50:27,957 [20220610_055027_00087_2.1.0-304] ERROR o.a.i.d.m.e.f.FragmentInstanceManager:113 - error when create FragmentInstanceExecution. org.apache.iotdb.db.exception.sql.StatementAnalyzeException: no data type found for path: count(root.bm68_dn62.g_0.d116_0.s_4) at org.apache.iotdb.db.mpp.plan.analyze.TypeProvider.getType(TypeProvider.java:47) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner$Visitor.getOutputColumnTypes(LocalExecutionPlanner.java:1324) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner$Visitor.visitTimeJoin(LocalExecutionPlanner.java:1010) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner$Visitor.visitTimeJoin(LocalExecutionPlanner.java:239) at org.apache.iotdb.db.mpp.plan.planner.plan.node.process.TimeJoinNode.accept(TimeJoinNode.java:91) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner$Visitor.visitFragmentSink(LocalExecutionPlanner.java:1070) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner$Visitor.visitFragmentSink(LocalExecutionPlanner.java:239) at org.apache.iotdb.db.mpp.plan.planner.plan.node.sink.FragmentSinkNode.accept(FragmentSinkNode.java:75) at org.apache.iotdb.db.mpp.plan.planner.LocalExecutionPlanner.plan(LocalExecutionPlanner.java:211) at org.apache.iotdb.db.mpp.execution.fragment.FragmentInstanceManager.lambda$execDataQueryFragmentInstance$1(FragmentInstanceManager.java:104) at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) at org.apache.iotdb.db.mpp.execution.fragment.FragmentInstanceManager.execDataQueryFragmentInstance(FragmentInstanceManager.java:90) at org.apache.iotdb.db.consensus.statemachine.DataRegionStateMachine.read(DataRegionStateMachine.java:139) at org.apache.iotdb.consensus.ratis.ApplicationStateMachineProxy.query(ApplicationStateMachineProxy.java:139) at org.apache.ratis.statemachine.impl.BaseStateMachine.queryStale(BaseStateMachine.java:194) at org.apache.ratis.server.impl.RaftServerImpl.staleReadAsync(RaftServerImpl.java:881) at org.apache.ratis.server.impl.RaftServerImpl.submitClientRequestAsync(RaftServerImpl.java:797) at org.apache.ratis.server.impl.RaftServerImpl.submitClientRequest(RaftServerImpl.java:912) at org.apache.ratis.server.impl.RaftServerProxy.submitClientRequest(RaftServerProxy.java:431) at org.apache.iotdb.consensus.ratis.RatisConsensus.read(RatisConsensus.java:229) at org.apache.iotdb.db.service.thrift.impl.InternalServiceImpl.sendFragmentInstance(InternalServiceImpl.java:124) at org.apache.iotdb.mpp.rpc.thrift.InternalService$Processor$sendFragmentInstance.getResult(InternalService.java:1265) at org.apache.iotdb.mpp.rpc.thrift.InternalService$Processor$sendFragmentInstance.getResult(InternalService.java:1245) 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.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) select count(s_4) from root.** ; // 结果正确 select COUNT(s_4) from root.** align by device; // COUNT 大写,加上align by device;正确 测试过程 1 . 192.168.130.3 /4/5 2. bm 配置见附件 运行起来后,cli执行查询。 -- This message was sent by Atlassian Jira (v8.20.7#820007)