Skip to content

Add SHOW RECEIVERS support#17869

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

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

Conversation

@Caideyipi

Copy link
Copy Markdown
Collaborator

Summary

  • add tree-model SHOW RECEIVERS and table-model information_schema.receivers support
  • track active pipe receiver sessions, sender endpoints, pipe IDs, handshake/transfer timestamps, and request counts
  • wire DataNode/ConfigNode thrift and air-gap receiver runtime recording

Tests

  • mvn "-Ddevelocity.off=true" -pl iotdb-core/node-commons -Dtest=PipeReceiverRuntimeRegistryTest test
  • mvn "-Ddevelocity.off=true" -DskipTests compile -pl iotdb-core/antlr,iotdb-core/relational-grammar,iotdb-core/node-commons,iotdb-core/confignode
  • mvn "-Ddevelocity.off=true" -DskipTests spotless:check -pl iotdb-core/node-commons,iotdb-core/datanode,iotdb-core/confignode,iotdb-core/relational-grammar,iotdb-core/antlr
  • git diff --check

Notes

  • DataNode focused compile is still blocked by unrelated generated Freemarker/calc symbols such as IFill, LinearFill, Accumulator, ComparatorChain, and IoTDBConfig.getModeMapSizeThreshold().
  • ConfigNode receiver records proxied through DataNode use receiver_node_id = -1 because the current proxy path does not expose the exact target ConfigNode id.

@Caideyipi Caideyipi marked this pull request as ready for review June 11, 2026 10:46
@codecov

codecov Bot commented Jun 11, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 59.04173% with 265 lines in your changes missing coverage. Please review.
✅ Project coverage is 41.11%. Comparing base (283bce2) to head (15e8980).
⚠️ Report is 6 commits behind head on master.

Files with missing lines Patch % Lines
...eceiver/protocol/thrift/IoTDBDataNodeReceiver.java 14.15% 97 Missing ⚠️
...b/queryengine/plan/planner/LogicalPlanBuilder.java 0.00% 24 Missing ⚠️
...iotdb/commons/pipe/receiver/IoTDBFileReceiver.java 59.18% 20 Missing ⚠️
...ipe/receiver/protocol/IoTDBConfigNodeReceiver.java 0.00% 18 Missing ⚠️
...db/db/queryengine/plan/analyze/AnalyzeVisitor.java 0.00% 18 Missing ⚠️
...ueryengine/plan/planner/OperatorTreeGenerator.java 0.00% 13 Missing ⚠️
...ecution/operator/source/ShowReceiversOperator.java 81.96% 11 Missing ⚠️
...an/planner/plan/node/source/ShowReceiversNode.java 54.54% 10 Missing ⚠️
...he/iotdb/commons/pipe/sink/protocol/IoTDBSink.java 30.00% 7 Missing ⚠️
...rotocol/thrift/async/IoTDBDataRegionAsyncSink.java 25.00% 6 Missing ⚠️
... and 18 more
Additional details and impacted files
@@             Coverage Diff              @@
##             master   #17869      +/-   ##
============================================
+ Coverage     40.95%   41.11%   +0.16%     
  Complexity      318      318              
============================================
  Files          5248     5263      +15     
  Lines        364224   365606    +1382     
  Branches      47043    47236     +193     
============================================
+ Hits         149155   150316    +1161     
- Misses       215069   215290     +221     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@sonarqubecloud

Copy link
Copy Markdown

Quality Gate Failed 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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant