You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:09:39 UTC

[jira] [Closed] (FLINK-1241) Record processing counter for Dashboard

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

Fabian Hueske closed FLINK-1241.
--------------------------------
    Resolution: Duplicate

Flink 0.10.0 added a new web dashboard which shows record counts at operator level. 
This makes this issue a duplicate of FLINK-766 which is about adding statistics about data sources and processed input splits.

[~stefano.bortoli] Please reopen this issue if you think that the remaining part of this issue is not covered by FLINK-766. Thanks!

> Record processing counter for Dashboard
> ---------------------------------------
>
>                 Key: FLINK-1241
>                 URL: https://issues.apache.org/jira/browse/FLINK-1241
>             Project: Flink
>          Issue Type: Improvement
>          Components: Webfrontend
>    Affects Versions: 0.8.0
>         Environment: Mozilla Firefox 33.0 for Ubuntu Canonical. Ubuntu 14.04 LTS
>            Reporter: Stefano Bortoli
>            Priority: Minor
>              Labels: counters, dashboard, monitoring, web-console
>
> It would be great to have a detail of the record processed by each of the split in the dashboard. If computing exact processing time is impossible, knowing the number of records would allow to estimate it roughly at least. (hours VS days, for example). It would also help to understand whether there is something odd going on as processing either perceived as too slow or too fast.
> There are issues related to this improvements:  FLINK-964, FLINK-766. 
> Furthermore, there is also an old GSoC proposal, which is related https://github.com/stratosphere/stratosphere/wiki/GSoC-2014-Project-Proposal-Draft-by-Rajika-Kumarasiri



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)