Skip to content

[To dev/1.3] Fix unbounded async pipe sink retries#18225

Merged
jt2594838 merged 1 commit into
apache:dev/1.3from
Caideyipi:backport-18222-to-dev-1.3
Jul 16, 2026
Merged

[To dev/1.3] Fix unbounded async pipe sink retries#18225
jt2594838 merged 1 commit into
apache:dev/1.3from
Caideyipi:backport-18222-to-dev-1.3

Conversation

@Caideyipi

Copy link
Copy Markdown
Collaborator

Description

Backport #18222 (5b311f6) to dev/1.3.

  • Bound async Pipe sink retries when a receiver remains temporarily unavailable.
  • After the retry limit, pause regular attempts and allow one receiver probe per configured interval.
  • Return async clients to the pool when a probe is delayed.
  • Add retry duration/probe interval configuration and targeted regression tests.

The 1.3 branch predates the main branch's scheduling-delay and i18n infrastructure, so this backport uses the existing non-report exception backoff and inline message style on dev/1.3.

Tests

  • mvn spotless:apply -pl iotdb-core/node-commons,iotdb-core/datanode
    • BUILD SUCCESS
  • mvn -o -nsu test -pl iotdb-core/datanode -am -Dtest=PipeSinkSubtaskTest,PipeTransferTrackableHandlerTest
    • Tests run: 11, Failures: 0, Errors: 0, Skipped: 0

@jt2594838
jt2594838 merged commit 8b10792 into apache:dev/1.3 Jul 16, 2026
16 checks passed
@jt2594838
jt2594838 deleted the backport-18222-to-dev-1.3 branch July 16, 2026 11:06
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