Skip to content

[INLONG-12120][SDK] Optimize worker selection logic in DataProxy Go SDK#12123

Merged
dockerzhang merged 1 commit into
apache:masterfrom
yfsn666:INLONG-12120
May 18, 2026
Merged

[INLONG-12120][SDK] Optimize worker selection logic in DataProxy Go SDK#12123
dockerzhang merged 1 commit into
apache:masterfrom
yfsn666:INLONG-12120

Conversation

@yfsn666
Copy link
Copy Markdown
Contributor

@yfsn666 yfsn666 commented May 15, 2026

Fixes #12120

Motivation

Optimize worker selection logic in DataProxy Go SDK to resolve the problem of a large number of ErrNoAvailableWorker errors occurring when some endpoint loads are high or become stuck.

Modifications

Modify the logic for selecting a worker when sending messages.

Verifying this change

(Please pick either of the following options)

  • This change is a trivial rework/code cleanup without any test coverage.

  • This change is already covered by existing tests, such as:
    (please describe tests)

  • This change added tests and can be verified as follows:

    (example:)

    • Added integration tests for end-to-end deployment with large payloads (10MB)
    • Extended integration test for recovery after broker failure

Documentation

  • Does this pull request introduce a new feature? no

Copy link
Copy Markdown
Contributor

@gunli gunli left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@dockerzhang dockerzhang merged commit d421b34 into apache:master May 18, 2026
9 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Improve][SDK] Optimize worker selection logic in DataProxy Go SDK

4 participants