[
https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666694#comment-15666694
]
ASF GitHub Bot commented on FLINK-5069:
---------------------------------------
GitHub user zhuhaifengleon opened a pull request:
https://github.com/apache/flink/pull/2809
[FLINK-5069] [Metrics] Pending checkpoint statistics gauge
This PR introduce pending checkpoints statistics gauge, which help to check
the state When checkpoints can't be done.
following is the statistics will be collected:
checkpointID,
Number Of Acknowledged Tasks,
Number Of Not yet Acknowledged Tasks,
The detail of not yet acknowledged JobVertexID, taskID
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhuhaifengleon/flink FLINK-5069
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2809.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2809
----
commit f94e28ed2276b470e408b7116c4ef5b227858df3
Author: zhuhaifengleon <zhu.haifeng.l...@gmail.com>
Date: 2016-11-15T09:29:09Z
[FLINK-5069] [Metrics] Pending checkpoint statistics gauge
----
> Pending checkpoint statistics gauge
> -----------------------------------
>
> Key: FLINK-5069
> URL: https://issues.apache.org/jira/browse/FLINK-5069
> Project: Flink
> Issue Type: Improvement
> Components: Metrics
> Reporter: zhuhaifeng
> Assignee: zhuhaifeng
> Priority: Minor
> Fix For: 1.2.0
>
>
> Add the statistics of pending checkpoints as a gauge metric. When the
> checkpoint appears not to be completed, this metric would help to get the
> state of a pending checkpoint , e.g which task did not complete the
> checkpoint.
> The statistic will be as the follows：
> checkpointID,
> Number Of Acknowledged Tasks,
> Number Of Not yet Acknowledged Tasks,
> The detail of not yet acknowledged JobVertexID, taskID
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
