Re: Flink Cluster Load Distribution Question

2016-09-19 Thread Amir Bahmanyari
ted to be processed in 3.5 hrs. >> - Kafka partitions in the kafka topic = total number of slots available in >> flink servers. Should I alter that for better performance? >> >> Thanks Aljoscha & have a great weekend. >> Amir- >> >> From: Aljoscha Krettek &l

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread amir bahmanyari
t: 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,Aljoscha On Tue, 13 Sep 2016 at 20:14 amir bahmanyari <amir

Re: Fw: Flink Cluster Load Distribution Question

2016-09-14 Thread amir bahmanyari
Have a wonderful day & thanks for your attention.Amir- From: Aljoscha Krettek <aljos...@apache.org> To: user@flink.apache.org; amir bahmanyari <amirto...@yahoo.com> Sent: Wednesday, September 14, 2016 1:48 AM Subject: Re: Fw: Flink Cluster Load Distribution Question Hi

Fw: Flink Cluster Load Distribution Question

2016-09-13 Thread amir bahmanyari
warded Message - From: Robert Metzger <rmetz...@apache.org> To: "d...@flink.apache.org" <d...@flink.apache.org>; amir bahmanyari <amirto...@yahoo.com> Sent: Tuesday, September 13, 2016 1:15 AM Subject: Re: Flink Cluster Load Distribution Question Hi Amir,