incubator-uniffle
incubator-uniffle copied to clipboard
[#2188] fix(client): Fixup timeoutMs for executeTasks in ShuffleWriteClientImpl#sendAppHeartbeat
What changes were proposed in this pull request?
(Please outline the changes and how this PR fixes the issue.)
Why are the changes needed?
The timeoutMs
in ShuffleWriteClientImpl#sendAppHeartbeat method. The timeoutMs for per RPC is similar to the timeoutMs of ThreadUtils#executeTasks` for all servers RPC execute, and the logic here is flawed.
Resetting the timeoutMs
for ThreadUtils.executeTask
.
Fix: #2188
Does this PR introduce any user-facing change?
No.
How was this patch tested?
no need