Enforce an operation to run in an exact host in flink
Locked
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.
|
||||||||||||||||
Re: Enforce an operation to run in an exact host in flink
|
|
Any help please?
On Thu, Nov 17, 2016 at 11:56 AM, Eranga Heshan <[hidden email]> wrote:
|
||||||||||||||||||||||||||||||||
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 <[hidden email]> wrote:
|
||||||||||||||||||||||||||||||||
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" <[hidden email]> wrote:
|
||||||||||||||||||||||||||||||||
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 pipeline on only one machine. On Fri, 18 Nov 2016 at 01:32 Eranga Heshan <[hidden email]> wrote:
|
||||||||||||||||||||||||||||||||
Re: Enforce an operation to run in an exact host in flink
|
|
Thank you Aijosha. 😃 I understood the concept.
On Mon, Nov 21, 2016 at 10:28 PM, Aljoscha Krettek <[hidden email]> wrote:
|
||||||||||||||||||||||||||||||||||||||||||||||||
| Free forum by Nabble | Edit this page |