[jira] [Created] (IOTDB-3449) [ COUNT query ] executeStatement failed. error code: TSStatus(code:411, message:Fragment cannot be dispatched)

["刘珍 (Jira)" <ji...@apache.org>]

刘珍 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)