(iotdb) branch RecordBlockedQuery updated: Correct status code from 301 to 719 while memory not enough

[jackietien]

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

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


The following commit(s) were added to refs/heads/RecordBlockedQuery by this 
push:
     new 511b1cfd195 Correct status code from 301 to 719 while memory not enough
511b1cfd195 is described below

commit 511b1cfd1957d8e95cb0d197c6986c01304f55a9
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Thu Jun 26 16:31:17 2025 +0800

    Correct status code from 301 to 719 while memory not enough
---
 .../queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
index a756a26df7f..a4f21d2f20f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
@@ -471,8 +471,7 @@ public class FragmentInstanceDispatcherImpl implements 
IFragInstanceDispatcher {
               } else if (sendFragmentInstanceResp.status.getCode()
                   == TSStatusCode.CONSENSUS_GROUP_NOT_EXIST.getStatusCode()) {
                 throw new 
ConsensusGroupNotExistException(sendFragmentInstanceResp.message);
-              } else if (sendFragmentInstanceResp.status.getCode()
-                  == 
TSStatusCode.TOO_MANY_CONCURRENT_QUERIES_ERROR.getStatusCode()) {
+              } else {
                 throw new 
FragmentInstanceDispatchException(sendFragmentInstanceResp.status);
               }
             } else if (sendFragmentInstanceResp.status != null) {
@@ -610,9 +609,7 @@ public class FragmentInstanceDispatcherImpl implements 
IFragInstanceDispatcher {
         if (!executionResult.isAccepted()) {
           LOGGER.warn(executionResult.getMessage());
           if (executionResult.isReadNeedRetry()) {
-            if (executionResult.getStatus() != null
-                && executionResult.getStatus().getCode()
-                    == 
TSStatusCode.TOO_MANY_CONCURRENT_QUERIES_ERROR.getStatusCode()) {
+            if (executionResult.getStatus() != null) {
               throw new 
FragmentInstanceDispatchException(executionResult.getStatus());
             }
             throw new FragmentInstanceDispatchException(