This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch RecordBlockedQuery-1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cf1ab04bdce294f18f4c91d5e8e854797f925590 Author: JackieTien97 <[email protected]> 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 7b4a4e30490..8dbfc148bb6 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 @@ -334,8 +334,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); } } @@ -456,9 +455,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { if (!readResult.isAccepted()) { LOGGER.warn(readResult.getMessage()); if (readResult.isReadNeedRetry()) { - if (readResult.getStatus() != null - && readResult.getStatus().getCode() - == TSStatusCode.TOO_MANY_CONCURRENT_QUERIES_ERROR.getStatusCode()) { + if (readResult.getStatus() != null) { throw new FragmentInstanceDispatchException(readResult.getStatus()); } throw new FragmentInstanceDispatchException(
