aglinxinyuan opened a new issue, #4765: URL: https://github.com/apache/texera/issues/4765
### Task Summary `GlobalReplayManager` (`amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/GlobalReplayManager.scala`) coordinates `onRecoveryStart` / `onRecoveryComplete` callbacks across recovering workers but currently has no unit tests. Add `GlobalReplayManagerSpec` covering: - `onRecoveryStart` fires on the first transition into recovery - `onRecoveryStart` does not refire while recovery is already in progress - `onRecoveryComplete` fires only after every recovering worker clears - `onRecoveryComplete` does not fire when no recovery was started - Repeated `markRecoveryStatus(_, true)` for the same worker is idempotent ### Priority P3 – Low ### Task Type - [x] Testing / QA -- 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]
