Skip to content

[To dev/1.3] [Pipe] Preserve downstream sink error messages (#18553) - #18570

Open
Caideyipi wants to merge 2 commits into
apache:dev/1.3from
Caideyipi:cp-18553-dev-1.3
Open

[To dev/1.3] [Pipe] Preserve downstream sink error messages (#18553)#18570
Caideyipi wants to merge 2 commits into
apache:dev/1.3from
Caideyipi:cp-18553-dev-1.3

Conversation

@Caideyipi

@Caideyipi Caideyipi commented Sep 2, 2026

Copy link
Copy Markdown
Collaborator

Description

Backport #18553 to dev/1.3.

Changes

  • Recursively select a concrete downstream receiver error from nested TSStatus responses instead of exposing only an aggregate wrapper.
  • Preserve the latest root-cause text in asynchronous retry summaries.
  • Clear stale retry failure text when retry queues drain, events are discarded, or the sink closes.
  • Add regression coverage for status propagation, retry-message formatting, and TsFile cleanup.

Adaptation

The implementation is adapted to the dev/1.3 tree-model APIs. This branch does not contain the master i18n message bundle, so the new retry templates are kept as local constants.

Verification

Not run, per request.

Source commit: 18ec5f0a393ed7cee0e3d30df5bf96e034d565d8


Key changed/added classes
  • PipeReceiverStatusHandler
  • IoTDBDataRegionAsyncSink
  • Pipe receiver and async sink regression tests

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