Gelly: akka.ask.timeout
Hey all,I have an iterative algorithm implemented in Gelly. As long as I upgraded everything to flink-1.3.1 from 1.1.2, the runtime has been increased and in some cases task managers are killed. The error msg is| "akka.ask.timeout". I increased akka.ask.timeout, but the problem still exist. Cheers,Alieh
Re: The two inputs have different execution contexts.
HiI was joining two datasets which were from two different ExecutionEnviornment. It was my mistake. Thanks anyway. Best,Alieh On Monday, 11 July 2016, 11:33, Kostas Kloudas <k.klou...@data-artisans.com> wrote: Hi Alieh, Could you share you code so that we can have a look?From the information you provide we cannot help. Thanks,Kostas On Jul 10, 2016, at 3:13 PM, Alieh Saeedi <a1_sae...@yahoo.com> wrote: I can not join or coGroup two tuple2 datasets of the same tome. The error is java.lang.IllegalArgumentException: The two inputs have different execution contexts.:-(
The two inputs have different execution contexts.
I can not join or coGroup two tuple2 datasets of the same tome. The error is java.lang.IllegalArgumentException: The two inputs have different execution contexts.:-(
LongMaxAggregator in gelly scatter/gather
Hi every bodyIs it possible to use org.apache.giraph.aggregators.LongMaxAggregator as an aggregator of gelly scatter/gather? Thanks in advance
LongMaxAggragator()
Hi everybody Why LongSumAggragator() works but LongMaxAggragator() is not known any more?! Thanks in advance
Gelly Scatter/Gather - Vertex update
Hi everybodyIn Gelly scatter/gather when no message is sent to a vertex in one iteration, it will not enter the scatter function in next iteration. Why? I need all vertices enter the scatter function in all iterations, but some of them receive a message and will be updated. thanks in advance
Gelly scatter/gather
HiIs it possible to access iteration number in gelly scatter/gather? thanks in advance
