You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Alieh <sa...@informatik.uni-leipzig.de> on 2017/04/28 11:58:33 UTC

gelly scatter/gather

Hi all

I have an iterative algorithm implemented using Gelly scatter/gather. 
Using 8 workers of a cluster, I encounter the error 
"akka.pattern.AskTimeoutException", which I think the reason is heap 
size. Surprisingly, using 4 workers of the same cluster, my program is 
executed!!! It seems that I have some I/O with 4 workers, but why using 
8 workers I can not run the job?

Best,

Alieh

Re: gelly scatter/gather

Posted by Till Rohrmann <tr...@apache.org>.
Hi Alieh,

where do you see the AskTimeoutException exactly? Maybe you can share the
complete stack trace and the logs with us. Moreover, which version of Flink
are you running?

Cheers,
Till
​

On Fri, Apr 28, 2017 at 2:13 PM, Kaepke, Marc <ma...@haw-hamburg.de>
wrote:

> Hi Alieh,
>
> I can't solve your problem yet. But I work with gelly and Scatter/Gather
> and later GSA too. Could you publish or show me your algorithm?
>
> Best from Hamburg
> Marc
>
> Sent from my iPhone
>
> > On 28. Apr 2017, at 13:58, Alieh <sa...@informatik.uni-leipzig.de>
> wrote:
> >
> > Hi all
> >
> > I have an iterative algorithm implemented using Gelly scatter/gather.
> Using 8 workers of a cluster, I encounter the error "akka.pattern.AskTimeoutException",
> which I think the reason is heap size. Surprisingly, using 4 workers of the
> same cluster, my program is executed!!! It seems that I have some I/O with
> 4 workers, but why using 8 workers I can not run the job?
> >
> > Best,
> >
> > Alieh
> >
>

Re: gelly scatter/gather

Posted by "Kaepke, Marc" <ma...@haw-hamburg.de>.
Hi Alieh,

I can't solve your problem yet. But I work with gelly and Scatter/Gather and later GSA too. Could you publish or show me your algorithm?

Best from Hamburg
Marc

Sent from my iPhone

> On 28. Apr 2017, at 13:58, Alieh <sa...@informatik.uni-leipzig.de> wrote:
> 
> Hi all
> 
> I have an iterative algorithm implemented using Gelly scatter/gather. Using 8 workers of a cluster, I encounter the error "akka.pattern.AskTimeoutException", which I think the reason is heap size. Surprisingly, using 4 workers of the same cluster, my program is executed!!! It seems that I have some I/O with 4 workers, but why using 8 workers I can not run the job?
> 
> Best,
> 
> Alieh
>