Skip to content

Add SHOW RECEIVERS support#17869

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

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

Merge remote-tracking branch 'origin/master' into tmp/resolve-pr-17869

bb17653
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 29, 2026 in 3m 6s

Quality Gate failed

Failed conditions
B 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 478 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 126 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/DataNodeLocationSupplierFactory.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label. 

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

Check warning on line 2161 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 288 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=AZ62XCipvX6AoKFRU2Tm&open=AZ62XCipvX6AoKFRU2Tm&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 279 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

Replace this instanceof check and cast with 'instanceof IoTDBSink iotdbsink' 

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

Check warning on line 352 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 386 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=AZ62XCipvX6AoKFRU2Tw&open=AZ62XCipvX6AoKFRU2Tw&pullRequest=17869

Check warning on line 476 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 rcurly' has incorrect indentation level 12, expected level should be 10. 

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

Check warning on line 341 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 failure on line 111 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 337 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

Move this method into "AggregatedRuntimeInfo". 

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

Check warning on line 3288 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 299 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 warning on line 4767 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 97 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 453 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=AZ62XCipvX6AoKFRU2T0&open=AZ62XCipvX6AoKFRU2T0&pullRequest=17869

Check warning on line 2181 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.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 71 to 64, Complexity from 15 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_0-r8qMT3U4uU8V&open=AZ67K_0-r8qMT3U4uU8V&pullRequest=17869

Check warning on line 481 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=AZ7YzacXeb9OVCgZLVrF&open=AZ7YzacXeb9OVCgZLVrF&pullRequest=17869

Check warning on line 319 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=AZ62XCipvX6AoKFRU2Tp&open=AZ62XCipvX6AoKFRU2Tp&pullRequest=17869

Check warning 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

Use super.clone() to create and seed the cloned instance to be returned. 

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

Check warning on line 363 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=AZ62XCipvX6AoKFRU2Tt&open=AZ62XCipvX6AoKFRU2Tt&pullRequest=17869

Check warning on line 2353 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 178 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 2934 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 83 to 64, Complexity from 17 to 14, Nesting Level from 4 to 2, Number of Variables from 20 to 6. 

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

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

Move this method into "AggregatedRuntimeInfo". 

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

Check warning on line 479 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=AZ7YzacXeb9OVCgZLVrE&open=AZ7YzacXeb9OVCgZLVrE&pullRequest=17869
View more details on SonarQubeCloud