Re: Flink Cluster Load Distribution Question

2016-09-20 Thread Aljoscha Krettek
flink servers. Should I alter that for better performance? >> >> Thanks Aljoscha & have a great weekend. >> Amir- >> >> -- >> *From:* Aljoscha Krettek >> *To:* Amir Bahmanyari ; user >> >> *Sent:* Sunday, Septe

Re: Flink Cluster Load Distribution Question

2016-09-18 Thread Amir Bahmanyari
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 >> To: Amir Bahmanyari ; user >&g

Re: Flink Cluster Load Distribution Question

2016-09-18 Thread Aljoscha Krettek
--- > *From:* Aljoscha Krettek > *To:* Amir Bahmanyari ; user > *Sent:* Sunday, September 18, 2016 1:48 AM > *Subject:* Re: Flink Cluster Load Distribution Question > > This is not related to Flink, but in Beam you can read from a directory > containing many files using somethi

Re: Flink Cluster Load Distribution Question

2016-09-18 Thread amir bahmanyari
ould I alter that for better performance? Thanks Aljoscha & have a great weekend.Amir- From: Aljoscha Krettek To: Amir Bahmanyari ; user Sent: Sunday, September 18, 2016 1:48 AM Subject: Re: Flink Cluster Load Distribution Question This is not related to Flink, but in Beam you

Re: Flink Cluster Load Distribution Question

2016-09-18 Thread Aljoscha Krettek
kafka topic >> partitions while #slots=64 is the same. >> >> Its still slow for a relatively large file though. >> Pls advice if something I can try to improve the cluster performance. >> Thanks+regards >> >> -- >> *From:* A

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
- taskmanager.network.bufferSizeInBytes > > Should I include it manually? Does it make any difference if the default > value i.e.32 KB doesn't get picked up? > Sorry too many questions. > Pls let me know. > I appreciate your help. > Cheers, > Amir- > > - Forwarded Messa

Fw: Flink Cluster Load Distribution Question

2016-09-13 Thread amir bahmanyari
Amir- - Forwarded Message - From: Robert Metzger To: "d...@flink.apache.org" ; amir bahmanyari Sent: Tuesday, September 13, 2016 1:15 AM Subject: Re: Flink Cluster Load Distribution Question Hi Amir, I would recommend to post such questions to the user@flink mailing lis