If I'm not mistaken Flink already has metrics that report latencies. These are not 100% correct because they machine one which an element originates is not necessarily the machine on which we measure the latency.
I'm afraid that that's the best we can do right now, however. Other than running your pipeline on only one machine. On Fri, 18 Nov 2016 at 01:32 Eranga Heshan <eranga....@gmail.com> wrote: > Yeah, I need to process latency. Any suggestions? > > On Nov 18, 2016 12:47 AM, "Aljoscha Krettek" <aljos...@apache.org> wrote: > > Hi, > I'm afraid that it is currently not possible to specify the machine on > which a Flink operator should run. What do you need this for? Are you > trying to measure processing latency? > > Cheers, > Aljoscha > > On Thu, 17 Nov 2016 at 09:15 Eranga Heshan <eranga....@gmail.com> wrote: > > Any help please? > > > Eranga Heshan > *Undergraduate* > Computer Science & Engineering > University of Moratuwa > Mobile: +94 71 138 2686 <%2B94%2071%20552%202087> > Email: era...@wso2.com <osanda.des...@gmail.com> > <https://www.facebook.com/erangaheshan> > <https://twitter.com/erangaheshan> > <https://www.linkedin.com/in/erangaheshan> > > On Thu, Nov 17, 2016 at 11:56 AM, Eranga Heshan <eranga....@gmail.com> > wrote: > > Hi all, > > I have 4 VMs. There is an input stream and an output stream in my job. To > get the exact time interval for an event to be processed, I need to run > both input and output bolts inside the same host/node. > > Is there a way to run a bolt inside a host we define? > > Thank you, > Regards, > > Eranga Heshan > *Undergraduate* > Computer Science & Engineering > University of Moratuwa > Mobile: +94 71 138 2686 <%2B94%2071%20552%202087> > Email: era...@wso2.com <osanda.des...@gmail.com> > <https://www.facebook.com/erangaheshan> > <https://twitter.com/erangaheshan> > <https://www.linkedin.com/in/erangaheshan> > > >
