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> > > >
