Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 834C518587 for ; Tue, 1 Sep 2015 10:49:03 +0000 (UTC) Received: (qmail 20864 invoked by uid 500); 1 Sep 2015 10:49:03 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 20804 invoked by uid 500); 1 Sep 2015 10:49:03 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 20793 invoked by uid 99); 1 Sep 2015 10:49:03 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Sep 2015 10:49:03 +0000 Received: from mail-io0-f181.google.com (mail-io0-f181.google.com [209.85.223.181]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id C4EB11A0040 for ; Tue, 1 Sep 2015 10:49:02 +0000 (UTC) Received: by iod35 with SMTP id 35so60523139iod.3 for ; Tue, 01 Sep 2015 03:49:01 -0700 (PDT) MIME-Version: 1.0 X-Received: by 10.107.10.103 with SMTP id u100mr2040882ioi.182.1441104541462; Tue, 01 Sep 2015 03:49:01 -0700 (PDT) Received: by 10.79.17.132 with HTTP; Tue, 1 Sep 2015 03:49:01 -0700 (PDT) In-Reply-To: <55E44337.3050201@informatik.hu-berlin.de> References: <5597EA3A57BF184588054E89ECCAA3D349AAA51D@szxeml559-mbx.china.huawei.com> <55E41F17.1050602@informatik.hu-berlin.de> <55E43128.8010002@informatik.hu-berlin.de> <5597EA3A57BF184588054E89ECCAA3D349AAA55D@szxeml559-mbx.china.huawei.com> <55E44337.3050201@informatik.hu-berlin.de> Date: Tue, 1 Sep 2015 12:49:01 +0200 Message-ID: Subject: =?UTF-8?Q?Re=3A_=E7=AD=94=E5=A4=8D=3A_Some_questions_about_storm_metrics?= From: Kostas Tzoumas To: "dev@flink.apache.org" Content-Type: multipart/alternative; boundary=001a113f901c473a73051ead4c42 --001a113f901c473a73051ead4c42 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Flink accumulators are documented here: https://ci.apache.org/projects/flink/flink-docs-master/apis/programming_gui= de.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? > > > > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D > > > > 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 > >> > >> 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 > >>>> =E5=8D=8E=E4=B8=BA=E6=8A=80=E6=9C=AF=E6=9C=89=E9=99=90=E5=85=AC=E5= =8F=B8 Huawei Technologies Co., Ltd. > >>>> > >>>> > >>>> Tel:+86 18106512602 > >>>> Email:huangwei111@huawei.com > >>>> > >>> > >>> > >> > > > > > > --001a113f901c473a73051ead4c42--