You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@iotdb.apache.org by "刘珍 (Jira)" <ji...@apache.org> on 2022/06/07 09:16:00 UTC

[jira] [Created] (IOTDB-3419) last query from root.** : Fragment cannot be dispatched

刘珍 created IOTDB-3419:
-------------------------

             Summary: last query from root.** : Fragment cannot be dispatched
                 Key: IOTDB-3419
                 URL: https://issues.apache.org/jira/browse/IOTDB-3419
             Project: Apache IoTDB
          Issue Type: Bug
          Components: mpp-cluster
    Affects Versions: 0.14.0-SNAPSHOT
            Reporter: 刘珍
            Assignee: Jinrui Zhang
         Attachments: config.properties.first, ip62_log_all.zip, ip66_log_all.log

master_0607_7cb2d3f

3confignode , 3 datanode , 
schema_replication_factor=3
data_replication_factor=3

After running the benchmark for 2 hours (configuration in the attachment) ,

ip66:  cli -h 192.168.10.62 -e "select last s_4 from root.**";

Msg: 500: [INTERNAL_SERVER_ERROR(500)] {color:#DE350B}Exception occurred: "select last s_4 from root.**". executeStatement failed. error code: TSStatus(code:411, message:Fragment cannot be dispatched){color}

*{color:#DE350B}error log :{color}*
2022-06-07 16:11:03,420 [pool-7-IoTDB-RPC-Client-114] WARN  o.a.i.d.u.ErrorHandlingUtils:62 - Status code: INTERNAL_SERVER_ERROR(500), operation: "select last s_4 from root.**". executeStatement failed
java.lang.RuntimeException: error code: TSStatus(code:411, message:Fragment cannot be dispatched)
        at org.apache.iotdb.db.service.thrift.impl.DataNodeTSIServiceImpl.executeStatement(DataNodeTSIServiceImpl.java:561)
        at org.apache.iotdb.service.rpc.thrift.TSIService$Processor$executeStatement.getResult(TSIService.java:2853)
        at org.apache.iotdb.service.rpc.thrift.TSIService$Processor$executeStatement.getResult(TSIService.java:2833)
        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)
2022-06-07 16:11:03,446 [pool-7-IoTDB-RPC-Client-114] INFO  o.a.i.d.q.c.SessionManager:150 - Session-257 is closing
2022-06-07 16:11:03,883 [pool-6-IoTDB-MPPCoordinatorScheduled-1] INFO  o.a.i.d.m.p.s.FixedRateFragInsStateTracker:75 - Instance 20220607_081103_01482_0.0.0's State is FINISHED
2022-06-07 16:11:04,420 [pool-4-IoTDB-MPPCoordinator-2] INFO  o.a.i.d.m.e.d.DataBlockManager$SourceHandleListenerImpl:207 - Query[20220607_081103_01481_0]-[0-0-SourceHandle-0]: onAborted is invoked
2022-06-07 16:11:04,420 [pool-4-IoTDB-MPPCoordinator-2] INFO  o.a.i.d.m.e.d.DataBlockManager$SourceHandleListenerImpl:188 - Query[20220607_081103_01481_0]-[0-0-SourceHandle-0] finished and release resources
2022-06-07 16:11:04,426 [pool-20-IoTDB-DataBlockManagerRPC-Client-3] ERROR o.a.t.ProcessFunction:47 - Internal error processing onEndOfDataBlockEvent
org.apache.thrift.TException: Target fragment instance not found. Fragment instance ID: TFragmentInstanceId(queryId:20220607_081103_01481_0, fragmentId:0, instanceId:0).
        at org.apache.iotdb.db.mpp.execution.datatransfer.DataBlockManager$DataBlockServiceImpl.onEndOfDataBlockEvent(DataBlockManager.java:165)
        at org.apache.iotdb.mpp.rpc.thrift.DataBlockService$Processor$onEndOfDataBlockEvent.getResult(DataBlockService.java:401)
        at org.apache.iotdb.mpp.rpc.thrift.DataBlockService$Processor$onEndOfDataBlockEvent.getResult(DataBlockService.java:381)
        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)
2022-06-07 16:11:05,433 [pool-20-IoTDB-DataBlockManagerRPC-Client-1] ERROR o.a.t.ProcessFunction:47 - Internal error processing onEndOfDataBlockEvent
org.apache.thrift.TException: Target fragment instance not found. Fragment instance ID: TFragmentInstanceId(queryId:20220607_081103_01481_0, fragmentId:0, instanceId:0).
        at org.apache.iotdb.db.mpp.execution.datatransfer.DataBlockManager$DataBlockServiceImpl.onEndOfDataBlockEvent(DataBlockManager.java:165)
        at org.apache.iotdb.mpp.rpc.thrift.DataBlockService$Processor$onEndOfDataBlockEvent.getResult(DataBlockService.java:401)
        at org.apache.iotdb.mpp.rpc.thrift.DataBlockService$Processor$onEndOfDataBlockEvent.getResult(DataBlockService.java:381)
        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)

test steps :
1. 192.168.10.62/66/68   72C 256G

start 3C3D cluster.

2. Benchmark connects to ip-62 to write data for 2 hours

3. ip-66 cli -h 192.168.10.62 -e "select last s_4 from root.**";
report an error



--
This message was sent by Atlassian Jira
(v8.20.7#820007)