Skip to content

[Query] Cancel dispatched fragment instances right away when the dispatch fails - #19085

Open
chrisdutz wants to merge 1 commit into
masterfrom
fix/query-terminate-on-dispatch-failure
Open

chrisdutz wants to merge 1 commit into
masterfrom
fix/query-terminate-on-dispatch-failure

[Query] Cancel dispatched fragment instances right away when the disp…

ba964d8
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 2, 2026 in 8m 25s

Quality Gate failed

Failed conditions
C Reliability Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 216 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/validate/TsFileOverlapValidationAndRepairTool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use "printf" instead of "String.format".

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb12BcLh6Xm1Y7fwlQ&open=AaGb12BcLh6Xm1Y7fwlQ&pullRequest=19085

Check warning on line 285 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 106).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb14XoLh6Xm1Y7fwmf&open=AaGb14XoLh6Xm1Y7fwmf&pullRequest=19085

Check warning on line 497 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 108).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb13qBLh6Xm1Y7fwlx&open=AaGb13qBLh6Xm1Y7fwlx&pullRequest=19085

Check warning on line 643 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 109).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb14EZLh6Xm1Y7fwl8&open=AaGb14EZLh6Xm1Y7fwl8&pullRequest=19085

Check warning on line 1017 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 112).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1y9YLh6Xm1Y7fwjD&open=AaGb1y9YLh6Xm1Y7fwjD&pullRequest=19085

Check warning on line 461 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 104).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1ureLh6Xm1Y7fwht&open=AaGb1ureLh6Xm1Y7fwht&pullRequest=19085

Check warning on line 726 in iotdb-client/cli/src/main/i18n/en/org/apache/iotdb/cli/i18n/CliMessages.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this String concatenation with Text block.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb17mmLh6Xm1Y7fwn-&open=AaGb17mmLh6Xm1Y7fwn-&pullRequest=19085

Check warning on line 393 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 112).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1uktLh6Xm1Y7fwhq&open=AaGb1uktLh6Xm1Y7fwhq&pullRequest=19085

Check warning on line 676 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 122).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb13niLh6Xm1Y7fwlv&open=AaGb13niLh6Xm1Y7fwlv&pullRequest=19085

Check warning on line 250 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 139).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb13v7Lh6Xm1Y7fwl0&open=AaGb13v7Lh6Xm1Y7fwl0&pullRequest=19085

Check warning on line 114 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteSmallRangeI64Scan.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use "printf" instead of "String.format".

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb112vLh6Xm1Y7fwk8&open=AaGb112vLh6Xm1Y7fwk8&pullRequest=19085

Check warning on line 4161 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 102).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1ygzLh6Xm1Y7fwiy&open=AaGb1ygzLh6Xm1Y7fwiy&pullRequest=19085

Check warning on line 96 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 157).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb15IHLh6Xm1Y7fwm4&open=AaGb15IHLh6Xm1Y7fwm4&pullRequest=19085

Check warning on line 468 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 123).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1ureLh6Xm1Y7fwhu&open=AaGb1ureLh6Xm1Y7fwhu&pullRequest=19085

Check warning on line 257 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 124).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb11bTLh6Xm1Y7fwke&open=AaGb11bTLh6Xm1Y7fwke&pullRequest=19085

Check warning on line 843 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/iotconsensusv2/IoTConsensusV2Receiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 172).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb10uELh6Xm1Y7fwjt&open=AaGb10uELh6Xm1Y7fwjt&pullRequest=19085

Check warning on line 85 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/PrintUtil.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 101).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1wDsLh6Xm1Y7fwiA&open=AaGb1wDsLh6Xm1Y7fwiA&pullRequest=19085

Check warning on line 292 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 108).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1yVULh6Xm1Y7fwiu&open=AaGb1yVULh6Xm1Y7fwiu&pullRequest=19085

Check warning on line 4203 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 128).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1ygzLh6Xm1Y7fwi0&open=AaGb1ygzLh6Xm1Y7fwi0&pullRequest=19085

Check warning on line 1174 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use an "AtomicBoolean" for this field; its operations are atomic.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb14ZwLh6Xm1Y7fwmi&open=AaGb14ZwLh6Xm1Y7fwmi&pullRequest=19085

Check warning on line 83 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/validate/TsFileOverlapValidationAndRepairTool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this use of System.out by a logger.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb12BcLh6Xm1Y7fwlH&open=AaGb12BcLh6Xm1Y7fwlH&pullRequest=19085

Check warning on line 1617 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 113).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1662Lh6Xm1Y7fwnT&open=AaGb1662Lh6Xm1Y7fwnT&pullRequest=19085

Check warning on line 354 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 151).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb11ZQLh6Xm1Y7fwka&open=AaGb11ZQLh6Xm1Y7fwka&pullRequest=19085

Check warning on line 805 in iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeSchemaMessages.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this String concatenation with Text block.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb12S4Lh6Xm1Y7fwld&open=AaGb12S4Lh6Xm1Y7fwld&pullRequest=19085

Check warning on line 2499 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/TreeAccessCheckVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 161).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1xkXLh6Xm1Y7fwic&open=AaGb1xkXLh6Xm1Y7fwic&pullRequest=19085