[iotdb] branch master updated: [IOTDB-6071] Fix internal server error when execute "show query processlist" statement (#10579)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 2b0bbce814d [IOTDB-6071] Fix internal server error when execute "show query processlist" statement (#10579)
2b0bbce814d is described below

commit 2b0bbce814dae8fe91c02cf0cc29fca748a39af6
Author: 马子坤 <55...@users.noreply.github.com>
AuthorDate: Tue Jul 18 16:26:45 2023 +0800

    [IOTDB-6071] Fix internal server error when execute "show query processlist" statement (#10579)
---
 .../plan/planner/distribution/SimpleFragmentParallelPlanner.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java
index 2730d858d15..2bf79e2a113 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java
@@ -103,7 +103,7 @@ public class SimpleFragmentParallelPlanner implements IFragmentParallelPlaner {
                 dataNodeFIMap.get(fragmentInstance.getHostDataNode()).size()));
 
     // compute dataNodeSeriesScanNum in LastQueryScanNode
-    if (analysis.getStatement().isQuery()
+    if (analysis.getStatement() instanceof QueryStatement
         && ((QueryStatement) analysis.getStatement()).isLastQuery()) {
       final Map<Path, AtomicInteger> pathSumMap = new HashMap<>();
       dataNodeFIMap