Skip to content

Support legacy pipe receiver requests#17901

Open
Caideyipi wants to merge 4 commits into
apache:masterfrom
Caideyipi:pipe-receiver-compat-13-sink-pr
Open

Support legacy pipe receiver requests#17901
Caideyipi wants to merge 4 commits into
apache:masterfrom
Caideyipi:pipe-receiver-compat-13-sink-pr

Conversation

@Caideyipi

@Caideyipi Caideyipi commented Jun 10, 2026

Copy link
Copy Markdown
Collaborator

Summary

  • Treat 1.3 pipe snapshot seal requests without tree/table capture flags as tree-model captures.
  • Use shared capture-flag helpers in DataNode and ConfigNode receivers.
  • Reuse raw tablet parsing for V1 batch tablet requests so 2.0 receivers can parse 1.3 Tablet serialization without column categories.
  • Add coverage for legacy raw tablet and multi-tablet batch payloads.

Tests

  • mvn -Ddevelocity.off=true spotless:apply -pl iotdb-core/node-commons,iotdb-core/datanode,iotdb-core/confignode
  • mvn -Ddevelocity.off=true -DskipTests compile -pl iotdb-core/node-commons
  • mvn -Ddevelocity.off=true spotless:apply -pl iotdb-core/datanode
  • mvn -Ddevelocity.off=true test -pl iotdb-core/datanode -Dtest=PipeDataNodeThriftRequestTest (blocked at existing datanode compile errors in generated aggregation code: missing ComparatorChain/getModeMapSizeThreshold)
  • mvn -Ddevelocity.off=true test -pl iotdb-core/datanode -am -Dtest=PipeDataNodeThriftRequestTest -Dsurefire.failIfNoSpecifiedTests=false (same datanode generated aggregation compile blocker)

@Caideyipi Caideyipi changed the title Support legacy pipe snapshot seal parameters Support legacy pipe receiver requests Jun 10, 2026
# Conflicts:
#	iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTabletRawReq.java
#	iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java
#	iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java
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