Re: Flink survey by data Artisans

From: Kostas Tzoumas To: "d...@flink.apache.org" ; user@flink.apache.org Sent: Friday, November 18, 2016 7:28 AM Subject: Flink survey by data Artisans Hi everyone! The Apache Flink community has evolved quickly over the past 2+ years,

Re: Why did the Flink Cluster JM crash?

expected.Thanks again. From: amir bahmanyari <amirto...@yahoo.com> To: Till Rohrmann <trohrm...@apache.org> Cc: "user@flink.apache.org" <user@flink.apache.org> Sent: Thursday, November 10, 2016 9:35 AM Subject: Re: Why did the Flink Cluster JM crash? Thanks Til

Re: Why did the Flink Cluster JM crash?

no expert there. Hope your experiments run well with these settings. Cheers,Till On Wed, Nov 9, 2016 at 8:02 PM, amir bahmanyari <amirto...@yahoo.com> wrote: Thanks Till.I have been trying out many many configuration combinations to get to the peak of what I can get as a reasonable perform

Re: Why did the Flink Cluster JM crash?

the test.I appreciate your response.Amir- From: Till Rohrmann <till.rohrm...@gmail.com> To: amir bahmanyari <amirto...@yahoo.com> Cc: "user@flink.apache.org" <user@flink.apache.org> Sent: Wednesday, November 9, 2016 1:27 AM Subject: Re: Why did the Flink Cluster J

Re: Why did the Flink Cluster JM crash?

StreamTask.java:56) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang.Thread.run(Thread.java:745) From: Till Rohrmann <till.rohrm...@gmail.com> To: user@flink.apache.org; amir bahmanyari <amirto...@yahoo.com> Sent:

Re: Why did the Flink Cluster JM crash?

OOps! sorry Till.I replicated it and I see exceptions in JM logs.How can I send the logs to you? or what "interesting" part of it do you need so I can copy/paste it here...Thanks From: Till Rohrmann <till.rohrm...@gmail.com> To: user@flink.apache.org; amir ba

Re: Why did the Flink Cluster JM crash?

Clean .No errors...no exceptions :-(Thanks Till. From: Till Rohrmann <till.rohrm...@gmail.com> To: user@flink.apache.org; amir bahmanyari <amirto...@yahoo.com> Sent: Tuesday, November 8, 2016 2:11 PM Subject: Re: Why did the Flink Cluster JM crash? Hi Amir, what does the

Why did the Flink Cluster JM crash?

Hi colleagues,I started the cluster all fine. Started the Beam app running in the Flink Cluster fine.Dashboard showed all tasks being consumed and open for business.I started sending data to the Beam app, and all of the sudden the Flink JM crashed.Exceptions below.Thanks+regardsAmir

Re: Flink Metrics

Hi colleagues,Is there a link that described Flink Matrices & provides example on how to utilize it pls?I really appreciate it...Cheers From: Till Rohrmann To: user@flink.apache.org Cc: d...@flink.apache.org Sent: Monday, October 17, 2016 12:52 AM Subject: Re:

Re: How can I prove ....

for their data exchange report?Thanks+regards,Amir- From: Stephan Ewen <se...@apache.org> To: user@flink.apache.org; amir bahmanyari <amirto...@yahoo.com> Cc: Felix Dreissig <f...@f30.me> Sent: Monday, September 26, 2016 2:18 AM Subject: Re: How can I prove You do not

Re: How can I prove ....

Thanks Felix.Interesting. I tried to create the JASON but didnt work  according to the sample code I found in docs.There is a way to get the same JASON from the command line.Is there an example?Thanks+regardsAmir- From: Felix Dreissig <f...@f30.me> To: amir bahmanyari &

Re: How can I prove ....

again Aljoscha. From: amir bahmanyari <amirto...@yahoo.com> To: Aljoscha Krettek <aljos...@apache.org>; User <user@flink.apache.org> Sent: Thursday, September 22, 2016 9:16 AM Subject: Re: How can I prove Thanks Aljoscha,Thats why I am wondering about this. I don

Re: How can I prove ....

: Aljoscha Krettek <aljos...@apache.org> To: amir bahmanyari <amirto...@yahoo.com>; User <user@flink.apache.org> Sent: Thursday, September 22, 2016 5:01 AM Subject: Re: How can I prove Hi,depending on the data source you might not be able to stress CPU/MEM because

How can I prove ....

That all nodes in a Flink Cluster are involved simultaneously in processing the data?Programmatically, graphically...I need to stress CPU , MEM and all resources to their max.How can I guarantee this is happening in Flink Cluster?Out of 4 nodes, this is the highest resource usage I see from

Re: Flink Cluster Load Distribution Question

which you start the program. You also have to make sure to > write to all partitions and not just to one. > > Cheers, > Aljoscha > >> On Sun, 18 Sep 2016 at 21:50 amir bahmanyari <amirto...@yahoo.com> wrote: >> Hi Aljoscha, >> Thanks for your kind response.

Re: Fw: Flink Cluster Load Distribution Question

Hi Aljoscha,The JM logs is also attached. Seems like everything is ok, assigned...to all nodes...Not sure why I dont get performance? :-(Thanks+regards,Amir- From: Aljoscha Krettek <aljos...@apache.org> To: user@flink.apache.org; amir bahmanyari <amirto...@yahoo.com> Sen

Re: Fw: Flink Cluster Load Distribution Question

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

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,