mwkang opened a new pull request, #8800: URL: https://github.com/apache/storm/pull/8800
## What is the purpose of the change `ReportWorkerHeartbeats` filtered stale heartbeats using only the global `supervisor.worker.timeout.secs`, but the kill authority `Slot.getHbTimeoutMs()` uses `max(topology.worker.timeout.secs, supervisor.worker.timeout.secs)`. A slow-but-alive worker of a topology with a longer timeout was dropped from the report one round before `Slot` would treat it as dead. This computes the effective timeout per topology to match `Slot`: `max(global, min(override, worker.max.timeout.secs))`, falling back to the global timeout when the topology conf can't be read. ## How was this patch tested Added unit tests for the per-topology override, the `worker.max.timeout.secs` cap, and the conf-read-failure fallback. `storm-server` build and checkstyle pass. Closes https://github.com/apache/storm/issues/8799 -- 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]
