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

[Query] Cancel dispatched fragment instances right away when the dispatch fails#19085
chrisdutz wants to merge 1 commit into
masterfrom
fix/query-terminate-on-dispatch-failure

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

3413b8a
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 5, 2026 in 9m 1s

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 431 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/Constants.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=AaGb17UWLh6Xm1Y7fwnt&open=AaGb17UWLh6Xm1Y7fwnt&pullRequest=19085

Check warning on line 2130 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.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=AaGb139hLh6Xm1Y7fwl4&open=AaGb139hLh6Xm1Y7fwl4&pullRequest=19085

Check warning on line 865 in iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/PipeMessages.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=AaGb1v7HLh6Xm1Y7fwh3&open=AaGb1v7HLh6Xm1Y7fwh3&pullRequest=19085

Check warning on line 24 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/airgap/AirGapPseudoTPipeTransferRequest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Override the "equals" method in this class. 

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

Check warning on line 587 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/QueryStatement.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 103). 

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

Check warning on line 1241 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 103). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb10lhLh6Xm1Y7fwjj&open=AaGb10lhLh6Xm1Y7fwjj&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 480 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 118). 

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

Check warning on line 216 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/Constants.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 210). 

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

Check warning on line 117 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 153). 

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

Check warning on line 301 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.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=AaGreqzygQdi0fvazngC&open=AaGreqzygQdi0fvazngC&pullRequest=19085

Check warning on line 346 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 123). 

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

Check warning on line 178 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 148). 

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

Check warning on line 694 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 111). 

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

Check warning on line 918 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

Replace this instanceof check and cast with 'instanceof IoTDBRuntimeException iotdbruntimeexception' 

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

Check warning on line 1366 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 102). 

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

Check warning on line 365 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/IoTDBSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 110). 

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

Check warning on line 442 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/client/IoTDBSyncClientManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 110). 

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

Check warning on line 183 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 119). 

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

Check failure on line 57 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeSubtaskExecutorManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Fix this access that will throw a NullPointerException when executed. 

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

Check warning on line 2495 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 114). 

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

Check warning on line 1404 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 116). 

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

Check warning on line 52 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 103). 

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

Check warning on line 256 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 113). 

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

Check warning on line 325 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/IoTDBAirGapSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 170). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb1udmLh6Xm1Y7fwhj&open=AaGb1udmLh6Xm1Y7fwhj&pullRequest=19085
View more details on SonarQubeCloud