Skip to content

[dev/1.3] Disable Subscription and Pipes containing data insertion under Ratis - #19157

Open
Caideyipi wants to merge 2 commits into
dev/1.3from
cp/19053-dev-1.3
Open

[dev/1.3] Disable Subscription and Pipes containing data insertion under Ratis#19157
Caideyipi wants to merge 2 commits into
dev/1.3from
cp/19053-dev-1.3

Preserve missing pipe start status on dev 1.3

ea9b76d
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Nov 6, 2026 in 1m 43s

Quality Gate passed

Issues
23 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
2.4% Duplication on New Code

See analysis details on SonarQube Cloud

Annotations

Check warning on line 343 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.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=AaGunO8m1VLkj8ktdBhx&open=AaGunO8m1VLkj8ktdBhx&pullRequest=19157

Check warning on line 889 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=AaGwIEWX4iRMcScK-Q_D&open=AaGwIEWX4iRMcScK-Q_D&pullRequest=19157

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

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

Check warning on line 142 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfoRatisTest.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=AaGunPnK1VLkj8ktdBh8&open=AaGunPnK1VLkj8ktdBh8&pullRequest=19157

Check warning on line 120 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=AaGunPNA1VLkj8ktdBhz&open=AaGunPNA1VLkj8ktdBhz&pullRequest=19157

Check warning on line 889 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=AaGwIEWX4iRMcScK-Q_E&open=AaGwIEWX4iRMcScK-Q_E&pullRequest=19157

Check warning on line 2843 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.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=AaGunPBy1VLkj8ktdBhy&open=AaGunPBy1VLkj8ktdBhy&pullRequest=19157

Check warning on line 260 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a static import for "mock". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEED4iRMcScK-Q_B&open=AaGwIEED4iRMcScK-Q_B&pullRequest=19157

Check warning on line 598 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=AaGwIEWX4iRMcScK-Q_C&open=AaGwIEWX4iRMcScK-Q_C&pullRequest=19157

Check warning on line 1610 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 108). 

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

Check warning on line 1597 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 101). 

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

Check warning on line 200 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a static import for "verify". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEED4iRMcScK-Q-9&open=AaGwIEED4iRMcScK-Q-9&pullRequest=19157

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

Refactor this method to reduce its Cognitive Complexity from 18 to the 15 allowed. 

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

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

Line is longer than 100 characters (found 110). 

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

Check failure on line 99 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgentTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Change this "try" to a try-with-resources. 

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

Check warning on line 69 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.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=AaGunPSp1VLkj8ktdBh2&open=AaGunPSp1VLkj8ktdBh2&pullRequest=19157

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

Remove this unused method parameter "pipeStaticMeta". 

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

Check warning on line 259 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a static import for "mock". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEED4iRMcScK-Q_A&open=AaGwIEED4iRMcScK-Q_A&pullRequest=19157

Check warning on line 336 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.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=AaGunO8m1VLkj8ktdBhw&open=AaGunO8m1VLkj8ktdBhw&pullRequest=19157

Check warning on line 194 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.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=AaGunPgG1VLkj8ktdBh4&open=AaGunPgG1VLkj8ktdBh4&pullRequest=19157

Check warning on line 219 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a static import for "mock". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEED4iRMcScK-Q--&open=AaGwIEED4iRMcScK-Q--&pullRequest=19157

Check warning on line 220 in iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a static import for "mock". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEED4iRMcScK-Q-_&open=AaGwIEED4iRMcScK-Q-_&pullRequest=19157

Check warning on line 894 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 IoTDBException iotdbexception' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwIEWX4iRMcScK-Q_F&open=AaGwIEWX4iRMcScK-Q_F&pullRequest=19157
View more details on SonarQubeCloud