Skip to content

Fix hybrid pipe queue memory admission across data regions - #19080

Merged
jt2594838 merged 1 commit into
masterfrom
fix/pipe-queue-memory-admission
Nov 2, 2026
Merged

jt2594838 merged 1 commit into
masterfrom
fix/pipe-queue-memory-admission

Fix hybrid pipe queue memory admission across data regions

f1a9373
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 2, 2026 in 7m 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 59 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/IoTDBDataDirViewer.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=AaGbjjIReNIArM0uBRy2&open=AaGbjjIReNIArM0uBRy2&pullRequest=19080

Check warning on line 409 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfo.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=AaGbjl6XeNIArM0uBR0i&open=AaGbjl6XeNIArM0uBR0i&pullRequest=19080

Check warning on line 220 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/validate/TsFileValidationTool.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=AaGbjjM2eNIArM0uBRy7&open=AaGbjjM2eNIArM0uBRy7&pullRequest=19080

Check warning on line 149 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.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=AaGbjl36eNIArM0uBR0d&open=AaGbjl36eNIArM0uBR0d&pullRequest=19080

Check warning on line 114 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/ImportTsFileOperation.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=AaGbjo0ueNIArM0uBR1Y&open=AaGbjo0ueNIArM0uBR1Y&pullRequest=19080

Check warning on line 69 in iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/binary/HmacColumnTransformer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 194).

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

Check warning on line 345 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 166).

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

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=AaGbjmg7eNIArM0uBR0x&open=AaGbjmg7eNIArM0uBR0x&pullRequest=19080

Check warning on line 343 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/DelayAnalyzer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 117).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGbji-CeNIArM0uBRym&open=AaGbji-CeNIArM0uBRym&pullRequest=19080

Check warning on line 47 in iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/RecordIterator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 107).

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

Check warning on line 387 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TsFileSketchTool.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=AaGbji76eNIArM0uBRyl&open=AaGbji76eNIArM0uBRyl&pullRequest=19080

Check warning on line 792 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 165).

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

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=AaGbjcYgeNIArM0uBRvu&open=AaGbjcYgeNIArM0uBRvu&pullRequest=19080

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=AaGbjk3leNIArM0uBRzo&open=AaGbjk3leNIArM0uBRzo&pullRequest=19080

Check warning on line 461 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 118).

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

Check warning on line 96 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileStatisticScan.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=AaGbjjACeNIArM0uBRyx&open=AaGbjjACeNIArM0uBRyx&pullRequest=19080

Check warning on line 472 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 180).

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

Check warning on line 229 in iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 134).

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

Check warning on line 208 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/PredicateWithUncorrelatedScalarSubqueryReconstructor.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=AaGbjeeYeNIArM0uBRwR&open=AaGbjeeYeNIArM0uBRwR&pullRequest=19080

Check warning on line 76 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/multi/FunctionViewExpression.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=AaGbjbZheNIArM0uBRve&open=AaGbjbZheNIArM0uBRve&pullRequest=19080

Check warning on line 1119 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 124).

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

Check warning on line 1660 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 156).

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

Check warning on line 378 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfo.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=AaGbjl6XeNIArM0uBR0h&open=AaGbjl6XeNIArM0uBR0h&pullRequest=19080

Check warning on line 91 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/an/AINodeClient.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=AaGbjgSieNIArM0uBRxA&open=AaGbjgSieNIArM0uBRxA&pullRequest=19080

Check warning on line 254 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=AaGbjfjieNIArM0uBRwo&open=AaGbjfjieNIArM0uBRwo&pullRequest=19080