Skip to content

[Bugfix] Disable Subscription and Pipes containing data insertion under Ratis - #19053

Open
Caideyipi wants to merge 14 commits into
masterfrom
codex/ratis-historical-replay-20261029
Open

[Bugfix] Disable Subscription and Pipes containing data insertion under Ratis#19053
Caideyipi wants to merge 14 commits into
masterfrom
codex/ratis-historical-replay-20261029

Merge branch 'master' of https://github.com/apache/iotdb into codex/r…

e967b7a
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 4, 2026 in 9m 22s

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 1222 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=AaGb0n5NoNGE37aOe3Gy&open=AaGb0n5NoNGE37aOe3Gy&pullRequest=19053

Check warning on line 583 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 105). 

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

Check warning on line 1685 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 175). 

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

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=AaGb0iepoNGE37aOe3Er&open=AaGb0iepoNGE37aOe3Er&pullRequest=19053

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'}' at column 32 should be alone on a line. 

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

Check warning on line 320 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 106). 

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

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

Replace this use of System.out by a logger. 

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

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=AaGb0lJBoNGE37aOe3GD&open=AaGb0lJBoNGE37aOe3GD&pullRequest=19053

Check warning on line 698 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 127). 

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

Check warning on line 552 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 132). 

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

Check failure on line 388 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

Fix this access that will throw a NullPointerException when executed. 

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

Check warning on line 1154 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 276). 

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Either log this exception and handle it, or rethrow it with some contextual information. 

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

Check warning on line 569 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.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=AaGb0goDoNGE37aOe3C_&open=AaGb0goDoNGE37aOe3C_&pullRequest=19053

Check warning on line 120 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TreeDeletionEntry treedeletionentry' 

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

Check warning on line 422 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 129). 

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

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=AaGb0gv-oNGE37aOe3DH&open=AaGb0gv-oNGE37aOe3DH&pullRequest=19053

Check warning on line 223 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 129). 

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

Check warning on line 309 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 130). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGb0gv-oNGE37aOe3DD&open=AaGb0gv-oNGE37aOe3DD&pullRequest=19053

Check warning on line 1648 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.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=AaGb0hZmoNGE37aOe3Dm&open=AaGb0hZmoNGE37aOe3Dm&pullRequest=19053

Check warning on line 54 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=AaGb0iepoNGE37aOe3Ep&open=AaGb0iepoNGE37aOe3Ep&pullRequest=19053

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=AaGb0d3ToNGE37aOe3CP&open=AaGb0d3ToNGE37aOe3CP&pullRequest=19053

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=AaGb0hkkoNGE37aOe3Dt&open=AaGb0hkkoNGE37aOe3Dt&pullRequest=19053

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

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

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

Check warning on line 63 in library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexReplace.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=AaGb0nRNoNGE37aOe3Gn&open=AaGb0nRNoNGE37aOe3Gn&pullRequest=19053
View more details on SonarQubeCloud