Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 96FA3200B73 for ; Mon, 29 Aug 2016 11:08:36 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 958E0160AB8; Mon, 29 Aug 2016 09:08:36 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DC143160AA7 for ; Mon, 29 Aug 2016 11:08:35 +0200 (CEST) Received: (qmail 91439 invoked by uid 500); 29 Aug 2016 09:08:35 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 91430 invoked by uid 99); 29 Aug 2016 09:08:34 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 29 Aug 2016 09:08:34 +0000 Received: from mail-it0-f44.google.com (mail-it0-f44.google.com [209.85.214.44]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 929AC1A0247 for ; Mon, 29 Aug 2016 09:08:34 +0000 (UTC) Received: by mail-it0-f44.google.com with SMTP id x131so92486585ite.0 for ; Mon, 29 Aug 2016 02:08:34 -0700 (PDT) X-Gm-Message-State: AE9vXwOXGYI+HEuo3dY/UzGMx50XsXbfxfsNN45Pa9JQb/GcF5YLLWgrWnFozuLM/nELi+SrN5XYnA7OnVyoBw== X-Received: by 10.36.127.7 with SMTP id r7mr13533154itc.49.1472461713980; Mon, 29 Aug 2016 02:08:33 -0700 (PDT) MIME-Version: 1.0 Received: by 10.107.171.7 with HTTP; Mon, 29 Aug 2016 02:08:33 -0700 (PDT) In-Reply-To: References: From: Stephan Ewen Date: Mon, 29 Aug 2016 11:08:33 +0200 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Programatically collect taskmanagers details from Job Manager To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1145bd846843a6053b3235e1 archived-at: Mon, 29 Aug 2016 09:08:36 -0000 --001a1145bd846843a6053b3235e1 Content-Type: text/plain; charset=UTF-8 You should be able to call the Monitor handler of the JobManager: http://jobmanagerhost:8081/taskmanagers That gives you a JSON response like this: { "taskmanagers [ { "id" : "7c8835b89acf533cb8a5119dbcaf4b4f", "path" : "akka.tcp://flink@127.0.1.1:56343/user/taskmanager", "dataPort" : 56199, "timeSinceLastHeartbeat" : 1472461577563, "slotsNumber" : 4, ....}, { "id " :"460bfbf8b540bf28befd616cbc9ea532", "path" : "akka.tcp://flink@127.0.1.1:58404/user/taskmanager", "dataPort" : 39233, "timeSinceLastHeartbeat" : 1472461577967, "slotsNumber":4, ....} ] } That should have the hostname/IP in the TaskManager URL: Hope that helps Stephan On Sun, Aug 28, 2016 at 3:03 PM, Sreejith S wrote: > Hi All, > > Is there any programmatic way to get the taskmanager details from a flink > clluster ? > > At least the IP of taskmanagers ? > > Thanks, > > -- > > > *Sreejith.S* > https://github.com/srijiths/ > tweet2sree@twitter > > > > > > > --001a1145bd846843a6053b3235e1 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
You should be able to call the Monitor handler of the JobM= anager: =C2=A0 http://j= obmanagerhost:8081/taskmanagers

That gives you a JSO= N response like this:=C2=A0

{ "taskmanagers [= =C2=A0=C2=A0
=C2=A0 { "id" : "7c8835b89acf533cb8a= 5119dbcaf4b4f",
=C2=A0 =C2=A0 "path" : "akka.= tcp://flink@127.0= .1.1:56343/user/taskmanager",
=C2=A0 =C2=A0 "dataPo= rt" : 56199,
=C2=A0 =C2=A0 "timeSinceLastHeartbeat"= ; : 1472461577563,
=C2=A0 =C2=A0 "slotsNumber" : 4,
=C2=A0 =C2=A0 ....},
=C2=A0 { "id " :"460bf= bf8b540bf28befd616cbc9ea532",
=C2=A0 =C2=A0 "path"= : "akka.tcp://flink@127.0.1.1:58404/user/taskmanager",
=C2=A0 =C2= =A0 "dataPort" : 39233,
=C2=A0 =C2=A0 "timeSinceLa= stHeartbeat" : 1472461577967,
=C2=A0 =C2=A0 "slotsNumbe= r":4,
=C2=A0 =C2=A0 ....}
]
}
=
That should have the hostname/IP in the TaskManager URL:
=

Hope that helps

Stephan<= /div>


On Sun, Aug 28, 2016 at 3:03 PM, Sreejith S <= srssreejith@gmai= l.com> wrote:
Hi All,

Is there any programmatic way to get the tas= kmanager details from a flink clluster ?

At least = the IP of taskmanagers ?

Thanks,

--001a1145bd846843a6053b3235e1--