[
https://issues.apache.org/jira/browse/IOTDB-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Tian reassigned IOTDB-3449:
--------------------------------
Assignee: Alima777 (was: Yuan Tian)
> [ 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: Alima777
> Priority: Major
> 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)
