Re: Enforce an operation to run in an exact host in flink

Thank you Aijosha. 😃 I understood the concept. Eranga Heshan *Undergraduate* Computer Science & Engineering University of Moratuwa Mobile: +94 71 138 2686 <%2B94%2071%20552%202087> Email: era...@wso2.com

Re: Enforce an operation to run in an exact host in flink

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

Re: Enforce an operation to run in an exact host in flink

Yeah, I need to process latency. Any suggestions? On Nov 18, 2016 12:47 AM, "Aljoscha Krettek" 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? > >

Re: Enforce an operation to run in an exact host in flink

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 wrote: > Any help please? > > > Eranga Heshan > *Und

Re: Enforce an operation to run in an exact host in flink

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

Enforce an operation to run in an exact host in flink

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 Hesha