Skip to content

[To dev/1.3] Fix Pipe leader cache isolation across receivers - #19077

Merged
jt2594838 merged 1 commit into
dev/1.3from
codex/cp-19064-dev13
Nov 2, 2026
Merged

jt2594838 merged 1 commit into
dev/1.3from
codex/cp-19064-dev13

Conversation

@Caideyipi

Copy link
Copy Markdown
Collaborator

Backports #19064 (59ac348a3f2954cbdbc5e53c01a3cd475a187880) onto dev/1.3 at 01a889cd5fd50bfe7d4eb3e6b24091c9ea634739.

Scope Pipe leader caches by the configured receiver endpoint set and device, and resolve tablet batch routing through the corresponding client manager. This prevents one sink from using another receiving cluster's cached leader.

The backport preserves the 1.3 client constructors and memory API, reproduces equivalent endpoint formatting locally, and adapts the test fixture and older Tablet API (schema type and explicit row count). Regression scenarios and assertions are preserved.

Validation:

  • Spotless passed for the affected modules.
  • Required IoTDB modules and dependencies compiled from source; the matching TsFile dependency was rebuilt from source.
  • 7 focused unit tests and both IoTDBPipeForwardIT methods passed under MultiClusterIT3, with no skipped tests. The new IT passed after the Tablet compatibility adaptation; the already-passing method was not repeated.
  • The new borrowing regression reproduced cross-receiver misrouting against the original target-base production classes.

@sonarqubecloud

sonarqubecloud Bot commented Nov 2, 2026

Copy link
Copy Markdown

@jt2594838
jt2594838 merged commit eda8986 into dev/1.3 Nov 2, 2026
16 of 18 checks passed
@jt2594838
jt2594838 deleted the codex/cp-19064-dev13 branch November 2, 2026 10:34
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.

2 participants