[FLINK-25632] Makes Job name available in cleanup stage

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.15.0
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 12/Jan/22 15:14
• Updated: 21/Feb/22 08:09

Description

CheckpointResourcesCleanupRunner implements the JobManagerRunner interface also providing ExecutionGraphInfo stub through requestJob (similar to what's returned by JobMasterServiceLeadershipRunner.requestJob returns when the JobMaster is still in initialization phase).

Currently, the job name is not passed as part of the ExecutionGraphInfo stub because it's not provided by the JobResult that stored in the JobResultStore. We have multiple options now to fix that:

1. JobResult is extended to also serve the job's name. As a consequence, it will be also present in the REST API
2. The JobResultStore stores this information as additional field besides the jobResult.