[jira] [Closed] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications

["Zhu Zhu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-38845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Zhu Zhu closed FLINK-38845.
---------------------------
    Fix Version/s: 2.3.0
       Resolution: Done

8c5735f0357d97e4d99475799d16dc74d26f1326

> Add ArchivedApplicationStore to manage terminated applications
> --------------------------------------------------------------
>
>                 Key: FLINK-38845
>                 URL: https://issues.apache.org/jira/browse/FLINK-38845
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Yi Zhang
>            Assignee: Yi Zhang
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.3.0
>
>
> Replace ExecutionGraphInfoStore with ArchivedApplicationStore to manage terminated applications (rather than individual jobs) and handle their expiration.
> With the introduction of applications, every job is now explicitly associated with an application. Previously, the {{ExecutionGraphInfoStore}} was used to manage and expire completed jobs individually. However, this approach no longer works well in the application-centric model.
> If we continue using {{ExecutionGraphInfoStore}} to expire individual completed jobs, it’s possible that only some jobs within an application get expired and removed, while others remain. This leads to an incomplete view of the application’s state, because parts of its job history become unavailable.
> To preserve application-level consistency and completeness, we introduce the {{{}ArchivedApplicationStore{}}}. Instead of expiring jobs independently, this new store manages entire applications (including all their jobs) as a whole, ensuring complete, consistent, and queryable application state until explicitly discarded.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)