Re: Fw: Flink Cluster Load Distribution Question

2016-09-17 Thread Aljoscha Krettek
anyari > *Sent:* Wednesday, September 14, 2016 1:48 AM > *Subject:* Re: Fw: Flink Cluster Load Distribution Question > > Hi, > this is a different job from the Kafka Job that you have running, right? > > Could you maybe post the code for that as well? > > Cheers, > Al

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread amir bahmanyari
: Re: Fw: Flink Cluster Load Distribution Question Hi,this is a different job from the Kafka Job that you have running, right? Could you maybe post the code for that as well? Cheers,Aljoscha On Tue, 13 Sep 2016 at 20:14 amir bahmanyari wrote: Hi Robert,Sure, I am forwarding it to user. Sorry about

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread amir bahmanyari
: Flink Cluster Load Distribution Question Hi,this is a different job from the Kafka Job that you have running, right? Could you maybe post the code for that as well? Cheers,Aljoscha On Tue, 13 Sep 2016 at 20:14 amir bahmanyari wrote: Hi Robert,Sure, I am forwarding it to user. Sorry about

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread amir bahmanyari
ve a wonderful day & thanks for your attention.Amir- From: Aljoscha Krettek To: user@flink.apache.org; amir bahmanyari Sent: Wednesday, September 14, 2016 1:48 AM Subject: Re: Fw: Flink Cluster Load Distribution Question Hi,this is a different job from the Kafka Job that

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread Aljoscha Krettek
Hi, this is a different job from the Kafka Job that you have running, right? Could you maybe post the code for that as well? Cheers, Aljoscha On Tue, 13 Sep 2016 at 20:14 amir bahmanyari wrote: > Hi Robert, > Sure, I am forwarding it to user. Sorry about that. I followed the > "robot's" instru

Fw: Flink Cluster Load Distribution Question

2016-09-13 Thread amir bahmanyari
Hi Robert,Sure, I am forwarding it to user. Sorry about that. I followed the "robot's" instructions :))Topology: 4 Azure A11 CentOS 7 nodes (16 cores, 110 GB). Lets call them node1, 2, 3, 4.Flink Clustered with node1 running JM & a TM. Three more TM's running on node2,3, and 4 respectively.I hav