[FLINK-24774] AdaptiveScheduler should inform job status listener of all state changes

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 04/Nov/21 14:40
• Updated: 12/Nov/21 13:49
• Resolved: 12/Nov/21 13:49

Description

The AdaptiveScheduler accepts a JobStatusListener, but only calls it for terminal states, which is a bit unexpected.

This also effectively sets up infrastructure for tracking all state changes from the AdaptiveScheduler alone, which will be useful for FLINK-21510 where we want to decouple state-related metrics from the EG.

Issue Links

• links to: GitHub Pull Request #17722