HyukjinKwon commented on PR #56729: URL: https://github.com/apache/spark/pull/56729#issuecomment-4788139158
Minimized the main (server-side) code change: instead of rewriting `send()` into a while-loop and switching its logging to plain string interpolation, this keeps the original `try/catch` and structured `log"…" + MDC(...)` logging untouched and only wraps `onNext` in a small bounded-retry helper that falls through to the **existing** cleanup path on the final failure. Production diff is now ~+20/−4 (was +73/−37); behavior is unchanged (3 attempts, 200ms backoff). Test diagnostics (`@volatile` + `diag(stage)`) are unchanged. Force-pushed the single commit. Note: this version lets an `InterruptedException` during the backoff sleep propagate (vs. explicitly restoring the interrupt flag); happy to add a one-line guard if preferred. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
