Skip to content

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

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

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

Address receiver review feedback

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

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

Check warning on line 513 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.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=AaGb0gB_oNGE37aOe3C6&open=AaGb0gB_oNGE37aOe3C6&pullRequest=19053

Check warning on line 1522 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.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=AaGb0iFFoNGE37aOe3EJ&open=AaGb0iFFoNGE37aOe3EJ&pullRequest=19053

Check warning on line 57 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/WindowsOSUtils.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 174). 

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

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

Check warning on line 407 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.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=AaGb0f7IoNGE37aOe3C4&open=AaGb0f7IoNGE37aOe3C4&pullRequest=19053

Check warning on line 113 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteOverPrecisedI64Scan.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=AaGb0iQNoNGE37aOe3Ed&open=AaGb0iQNoNGE37aOe3Ed&pullRequest=19053

Check warning on line 603 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 109). 

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

Check warning on line 265 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/CommonUtils.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=AaGb0hBYoNGE37aOe3DX&open=AaGb0hBYoNGE37aOe3DX&pullRequest=19053

Check warning on line 155 in external-service-impl/rest/src/main/java/org/apache/iotdb/rest/RestService.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Abbreviation in name 'configureSSL' must contain no more than '2' consecutive capital letters. 

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

Check warning on line 1839 in iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeMiscMessages.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=AaGb0i0HoNGE37aOe3FC&open=AaGb0i0HoNGE37aOe3FC&pullRequest=19053

Check warning on line 1928 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.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=AaGb0k-uoNGE37aOe3F9&open=AaGb0k-uoNGE37aOe3F9&pullRequest=19053

Check warning on line 2101 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 145). 

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

Check warning on line 456 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.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=AaGb0gB_oNGE37aOe3C5&open=AaGb0gB_oNGE37aOe3C5&pullRequest=19053

Check warning on line 167 in iotdb-client/cli/src/main/java/org/apache/iotdb/cli/Cli.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 131). 

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

Check warning on line 124 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgent.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=AaGL0LCd3cWvfkLdHfmv&open=AaGL0LCd3cWvfkLdHfmv&pullRequest=19053

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

Check warning on line 95 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/visibility/VisibilityTestUtils.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=AaGb0akZoNGE37aOe3Bb&open=AaGb0akZoNGE37aOe3Bb&pullRequest=19053

Check warning on line 3078 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 144). 

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

Check warning on line 1568 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.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=AaGb0k-uoNGE37aOe3Fz&open=AaGb0k-uoNGE37aOe3Fz&pullRequest=19053

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

Check warning on line 591 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 125). 

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

Check warning on line 77 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ExportTsFile.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Change this instance-reference to a static reference. 

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

Check warning on line 68 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TsFileResourcePrinter.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=AaGb0ijHoNGE37aOe3E6&open=AaGb0ijHoNGE37aOe3E6&pullRequest=19053
View more details on SonarQubeCloud