beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ben Chambers (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-773) Implement Metrics support for Flink runner
Date Thu, 29 Dec 2016 18:08:58 GMT

    [ https://issues.apache.org/jira/browse/BEAM-773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15785789#comment-15785789
] 

Ben Chambers commented on BEAM-773:
-----------------------------------

I'm not sure that it is being worked on currently. If you're interested in working on this,
it would probably worth having a discussion on the mailing list to get some guidance from
the Flink experts on how this should be implemented. My best guess would be that it should
involve connecting Beam Metrics to Flink Metrics, although that will only support getting
the attempted values (eg., it will count all attempts across retries). I'm also happy to discuss
what has been built so far and how it is wired up to the Direct Runner.

> Implement Metrics support for Flink runner
> ------------------------------------------
>
>                 Key: BEAM-773
>                 URL: https://issues.apache.org/jira/browse/BEAM-773
>             Project: Beam
>          Issue Type: Sub-task
>          Components: runner-flink
>            Reporter: Ben Chambers
>




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

Mime
View raw message