flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Tzoumas <ktzou...@apache.org>
Subject Re: 答复: Some questions about storm metrics
Date Tue, 01 Sep 2015 10:49:01 GMT
Flink accumulators are documented here:
https://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#accumulators--counters

I think Aljoscha's idea is to implement Storm metrics on top of those.

Huangwei, perhaps you can look whether the interfaces match (basically if
Flink accumulators have all the features needed to support the kinds of
metrics that Storm exposes, or if there is a significant impedance
mismatch).

On Mon, Aug 31, 2015 at 2:06 PM, Matthias J. Sax <
mjsax@informatik.hu-berlin.de> wrote:

> I did not look into it and I am not super familiar with Flink's
> accumulators... Can not provide much help right now. Sorry :(
>
> -Matthias
>
> On 08/31/2015 01:01 PM, huangwei (G) wrote:
> > Hi,
> > I think I can take a simple design for it.
> > Do you have any idea?
> >
> > ========================================
> >
> > Maybe. I did not put any thoughts into this...
> >
> > On 08/31/2015 12:25 PM, Aljoscha Krettek wrote:
> >> Hi,
> >> could the metrics not be implemented on top of Flink accumulators?
> >> They would even be live-updated in the new web front-end.
> >>
> >> Cheers,
> >> Aljoscha
> >>
> >> On Mon, 31 Aug 2015 at 11:32 Matthias J. Sax
> >> <mjsax@informatik.hu-berlin.de>
> >> wrote:
> >>
> >>> Hi,
> >>>
> >>> custom metrics are currently not supported by the compatibility layer.
> >>> See README here:
> >>>
> >>> https://github.com/apache/flink/tree/master/flink-contrib/flink-storm
> >>> -compatibility/flink-storm-compatibility-core
> >>>
> >>> It is an open question, if/how Flink can support this feature.
> >>>
> >>> -Matthias
> >>>
> >>> On 08/31/2015 09:53 AM, huangwei (G) wrote:
> >>>> Hi Matthias and all,
> >>>>
> >>>> I`d like to do the custom metrics in flink-storm-compatibility.
> >>>> And there are some questions following:
> >>>> Is there anything like storm metrics in Flink?
> >>>> If not, does Flink need to have metrics mechanism in internal first?
> >>>> Or just let the metrics use in flink-storm-compatibility?
> >>>>
> >>>>
> >>>> Greetings,
> >>>> Huang Wei
> >>>> 华为技术有限公司 Huawei Technologies Co., Ltd.
> >>>>
> >>>>
> >>>> Tel:+86 18106512602
> >>>> Email:huangwei111@huawei.com
> >>>>
> >>>
> >>>
> >>
> >
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message