You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "David Morávek (Jira)" <ji...@apache.org> on 2023/07/04 07:49:00 UTC
[jira] [Commented] (FLINK-32469) Simplify the implementation of the checkpoint handlers
[ https://issues.apache.org/jira/browse/FLINK-32469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739832#comment-17739832 ]
David Morávek commented on FLINK-32469:
---------------------------------------
Can you please try to rephrase the title/description/ PR so it's centered around the issue this is trying to solve? I believe the motivation is not to "simplify the implementation (which is subjective)" but to provide a better experience by reworking the caching mechanics. It's always easier to reason about things when the goal is clear.
> Simplify the implementation of the checkpoint handlers
> ------------------------------------------------------
>
> Key: FLINK-32469
> URL: https://issues.apache.org/jira/browse/FLINK-32469
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / REST
> Affects Versions: 1.16.2, 1.17.1
> Reporter: Hong Liang Teoh
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.18.0
>
>
> *What*
> The checkpoint handlers currently retrieve checkpoint information from the `ExecutionGraph`, which is cached in the `AbstractExecutionGraphHandler`. This means that this information is potentially stale (depending on the `web.refresh-interval`, which defaults to 3s).
> We want to make the checkpoint handlers directly retrieve the latest `CheckpointStatsSnapshot` object instead of relying on the cached `ExecutionGraph`.
> *Why*
> We want to enable programmatic use of the REST API, independent of the Flink dashboard.
> The current configuration of the `ExecutionGraph` cache is meant to facilitate a fluid user experience of the Flink dashboard. On the Job details page, the Flink dashboard makes a series of requests (e.g. /jobs/\{jobid}, /jobs/\{jobid}/vertices/\{vertexid}){color:#172b4d}. {color}
> {color:#172b4d}To ensure that the requests return consistent results, we have the execution graph cache.{color}
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)