Skip to content

[To dev/1.3][Pipe] Back off async sink for all retry statuses (#18236) - #18252

Merged
jt2594838 merged 1 commit into
apache:dev/1.3from
Caideyipi:cp-94b07e0-dev-1.3
Jul 21, 2026
Merged

[To dev/1.3][Pipe] Back off async sink for all retry statuses (#18236)#18252
jt2594838 merged 1 commit into
apache:dev/1.3from
Caideyipi:cp-94b07e0-dev-1.3

Conversation

@Caideyipi

Copy link
Copy Markdown
Collaborator

Description

Backport

Backport 94b07e0 (#18236) to dev/1.3.

Changes

  • Generalize async sink receiver backoff from temporary-unavailable/write-reject statuses to every non-success response, including nested sub-statuses.
  • Keep SUCCESS_STATUS and REDIRECTION_RECOMMEND as successful responses that clear endpoint backoff.
  • Preserve the existing exponential backoff, serialized retry, maximum retry duration, and probe behavior.
  • Adapt the updated messages to the inline-message structure used by dev/1.3.

Tests

  • Cover INTERNAL_SERVER_ERROR to verify that retries for non-memory failures are serialized by endpoint backoff.
  • Verified with:
    • mvn spotless:apply -pl iotdb-core/datanode
    • mvn -o -nsu test -Ddevelocity.off=true -pl iotdb-core/datanode -Dtest=PipeTransferTrackableHandlerTest -Dsurefire.failIfNoSpecifiedTests=false

This PR has:

  • been self-reviewed.
  • added or modified unit tests to cover the changed path.

Key changed classes
  • IoTDBDataRegionAsyncSink
  • PipeTransferTrackableHandler
  • PipeTransferTrackableHandlerTest

@jt2594838
jt2594838 merged commit a9f69c3 into apache:dev/1.3 Jul 21, 2026
16 checks passed
@jt2594838
jt2594838 deleted the cp-94b07e0-dev-1.3 branch July 21, 2026 01:55
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