Skip to content

Add SHOW RECEIVERS support#17869

Open
Caideyipi wants to merge 44 commits into
masterfrom
feat/show-receivers
Open

Add SHOW RECEIVERS support#17869
Caideyipi wants to merge 44 commits into
masterfrom
feat/show-receivers

Fix old pipe sender receiver runtime handshake

9fa79cc
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Jul 9, 2026 in 3m 35s

Quality Gate passed

Issues
52 New issues
0 Accepted issues

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

See analysis details on SonarQube Cloud

Annotations

Check warning on line 881 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use "java.util.List.of()" instead. 

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

Check warning on line 55 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistry.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Method has 11 parameters, which is greater than 7 authorized. 

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

Check warning on line 2172 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AstBuilder.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 89 to 64, Complexity from 27 to 14, Nesting Level from 4 to 2, Number of Variables from 9 to 6. 

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

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

'block lcurly' has incorrect indentation level 12, expected level should be 10. 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

Check warning on line 3303 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 104 to 64, Complexity from 19 to 14, Nesting Level from 5 to 2, Number of Variables from 29 to 6. 

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

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

'block' child has incorrect indentation level 14, expected level should be 12. 

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

Check failure on line 112 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtask.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

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

'finally rcurly' has incorrect indentation level 14, expected level should be 12. 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

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

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

Check warning on line 377 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 111). 

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

Check warning on line 152 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 92 to 64, Complexity from 16 to 14, Nesting Level from 3 to 2, Number of Variables from 7 to 6. 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

Check failure on line 67 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/ShowReceiversNode.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this "clone" implementation; use a copy constructor or copy factory instead. 

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

Check warning on line 37 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeSnapshot.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Constructor has 12 parameters, which is greater than 7 authorized. 

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

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

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 189 to 64, Complexity from 21 to 14, Nesting Level from 4 to 2, Number of Variables from 22 to 6. 

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

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

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 99 to 64, Complexity from 20 to 14, Nesting Level from 3 to 2, Number of Variables from 14 to 6. 

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

Check warning on line 153 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistry.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this "Map.get()" and condition with a call to "Map.computeIfAbsent()". 

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

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

'try' child has incorrect indentation level 16, expected level should be 14. 

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

Check warning on line 53 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/ShowReceiversNode.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use "java.util.List.of()" instead. 

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

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

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 109 to 64, Complexity from 17 to 14, Nesting Level from 3 to 2, Number of Variables from 16 to 6. 

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