Skip to content

[INLONG-12121][SDK] Log remote server address on send timeout and server errors in DataProxy Go SDK - #12124

Merged
dockerzhang merged 2 commits into
apache:masterfrom
yfsn666:INLONG-12121
May 18, 2026
Merged

[INLONG-12121][SDK] Log remote server address on send timeout and server errors in DataProxy Go SDK#12124
dockerzhang merged 2 commits into
apache:masterfrom
yfsn666:INLONG-12121

Conversation

@yfsn666

@yfsn666 yfsn666 commented May 15, 2026

Copy link
Copy Markdown
Contributor

Fixes #12121

Motivation

Log remote server address on send timeout and server errors in DataProxy Go SDK to facilitate troubleshooting on the server side.

Modifications

Record the remote server address when sending batch messages and print it to the logs.

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

@gunli gunli left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

LGTM

Comment thread inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go Outdated
@dockerzhang
dockerzhang merged commit 4307016 into apache:master May 18, 2026
8 checks passed
gunli added a commit to Tencent/game-log-sdk-go that referenced this pull request May 27, 2026
Failure logs previously only showed the error and batch metadata,
making it hard to tell which backend a failed write was targeting.
Record the remote address at dispatch time and include it in every
send/retry/timeout/heartbeat/server-error log path.

- connpool: export getRemoteAddr as GetRemoteAddr so callers outside
  the package can reuse the RemoteAddr -> ConnContext.Endpoint
  fallback (handles UDP and peer-closed conns where RemoteAddr is
  nil).
- tglog: add batchReq.lastSendServerAddr, set it in sendBatch right
  after fetching the conn, and surface it in the relevant logs.
- tglog: also log a warn on server-error responses (previously
  silently translated to errServerError).

Inspired by apache/inlong#12124.
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] Log remote server address on send timeout and server errors in DataProxy Go SDK

4 participants