Hey Timur, is it possible to connect to the VMs and get stack traces of the Flink processes as well?
We can first have a look at the logs, but the stack traces will be helpful if we can't figure out what the issue is. – Ufuk On Tue, Apr 26, 2016 at 9:42 AM, Till Rohrmann <trohrm...@apache.org> wrote: > Could you share the logs with us, Timur? That would be very helpful. > > Cheers, > Till > > On Apr 26, 2016 3:24 AM, "Timur Fayruzov" <timur.fairu...@gmail.com> wrote: >> >> Hello, >> >> Now I'm at the stage where my job seem to completely hang. Source code is >> attached (it won't compile but I think gives a very good idea of what >> happens). Unfortunately I can't provide the datasets. Most of them are about >> 100-500MM records, I try to process on EMR cluster with 40 tasks 6GB memory >> for each. >> >> It was working for smaller input sizes. Any idea on what I can do >> differently is appreciated. >> >> Thans, >> Timur
