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 >> <mj...@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:huangwei...@huawei.com >>>> >>> >>> >> > >
signature.asc
Description: OpenPGP digital signature