Skip to content

Add SHOW RECEIVERS support#17869

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

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

Merge remote-tracking branch 'origin/master' into feat/show-receivers

ffb798e
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 23, 2026 in 3m 18s

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 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 171 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaContentSupplierFactory.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 80 to 64, Complexity from 26 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_4Tr8qMT3U4uU8X&open=AZ67K_4Tr8qMT3U4uU8X&pullRequest=17869

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

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

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ62XCipvX6AoKFRU2Tv&open=AZ62XCipvX6AoKFRU2Tv&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 warning on line 190 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 "SessionRuntimeInfo". 

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

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

A Singleton implementation was detected. Make sure the use of the Singleton pattern is required and the implementation is the right one for the context. 

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

Check warning on line 46 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/PipeReceiverRuntimeSnapshotFilter.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this usage of 'Stream.collect(Collectors.toList())' with 'Stream.toList()' and ensure that the list is unmodified. 

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

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

This class overrides "hashCode()" and should therefore also override "equals()". 

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

Check warning on line 2055 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 81 to 64, Complexity from 29 to 14, Nesting Level from 4 to 2, Number of Variables from 10 to 6. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ67K_uMr8qMT3U4uU8Q&open=AZ67K_uMr8qMT3U4uU8Q&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 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 400 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=AZ62XCipvX6AoKFRU2Ty&open=AZ62XCipvX6AoKFRU2Ty&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 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 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 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 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 276 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=AZ62XCipvX6AoKFRU2Tx&open=AZ62XCipvX6AoKFRU2Tx&pullRequest=17869

Check warning on line 421 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 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
View more details on SonarQubeCloud