Repository navigation
Add SHOW RECEIVERS support - #17869
Merged
Merged
Conversation
Caideyipi
marked this pull request as ready for review
June 11, 2026 10:46
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## master #17869 +/- ##
============================================
+ Coverage 42.65% 42.81% +0.16%
- Complexity 414 442 +28
============================================
Files 5451 5451
Lines 394061 395406 +1345
Branches 51608 51798 +190
============================================
+ Hits 168089 169303 +1214
- Misses 225972 226103 +131 ☔ View full report in Codecov by Harness. 🚀 New features to boost your workflow:
|
# Conflicts: # iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiverTest.java
# Conflicts: # iotdb-core/relational-grammar/src/main/antlr4/org/apache/iotdb/db/relational/grammar/sql/RelationalSql.g4
…ow-receivers # Conflicts: # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/TreeAccessCheckVisitor.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementVisitor.java # iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSinkTest.java
# Conflicts: # iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java # iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java
…ow-receivers # Conflicts: # iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSinkTest.java
…ow-receivers # Conflicts: # integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeReceiverIT.java # integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java # iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverTest.java
|
jt2594838
reviewed
Aug 27, 2026
…ow-receivers # Conflicts: # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManager.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ConfigNodeClient.java # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ConfigNodeInfo.java
jt2594838
approved these changes
Sep 14, 2026
VGalaxies
pushed a commit
to VGalaxies/iotdb
that referenced
this pull request
Oct 26, 2026
* Add show receivers support * Fix show receivers runtime edge cases * Fix receiver handshake body duplication * Fix show receivers schema alignment * Add show receivers visibility and HA tests * Add show receivers edge case tests * Add show receivers schema filter tests * Add show receivers permission IT * Fix pipe handshake request body reuse * Add show receivers test coverage * Add show receivers initial transfer time tests * Add show receivers lifecycle test coverage * Add sort * Add aggregation UT * Add information_schema.receivers UT * Fix pipe IT * fix-information-ci * Fix * recv-fix * ignore ts * i18n * Fix ci failure * Added ut/it * Update IoTDBShowReceiversLifecycleIT.java * Update StatementGeneratorTest.java * Added tests * Add test * Test * Delete use pipe ut * Update IoTDBShowReceiversLifecycleIT.java * Fix show receivers pipe cleanup * Fix wd * Tag write-back receiver runtime separately * Add show receivers integration coverage * Fix show receivers runtime metadata tests * Fix receiver runtime cleanup test * Remove unused session runtime hash code * Fix old pipe sender receiver runtime handshake * Fix null-safe tree user audit comparison * [IT] Fix receiver test merge selection * [Pipe] Preserve receiver sessions across region task lifecycle * Address SHOW RECEIVERS review comments
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Tests
Notes