breaking the pipe line

. Is there any other more efficient way to do it? Best, Alieh

Re: runtime.resourcemanager

Hello, this is the task manage log but it does not change after I run the program.  I think the Flink planner has problem with my program. It can not even start the job. Best, Alieh 018-12-10 12:20:20,386 INFO

Re: runtime.resourcemanager

this time I see the job manager logs as I mentioned before),  the job is started and can be executed in 2 seconds. Best, Alieh On 12/07/2018 10:43 AM, Piotr Nowojski wrote: Hi, Please investigate logs/standard output/error from the task manager that has failed (the logs that you showed

runtime.resourcemanager

run it with a toy example of a graph with less that 10 vertices. Do you have any clue what is the problem? Cheers, Alieh 129149 [flink-akka.actor.default-dispatcher-20] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request. 129149 [flink

Gelly: akka.ask.timeout

till exist. Cheers,Alieh

bulk iteration

Hello all, even though I asked this question before, I lost my emails. So I have to ask again. Using Bulk iteration, is there any way to know the number of iterations? Cheers, Alieh

Bulk Iteration

Hello all, using Bulk iteration, is there any way to know the number of iterations? Cheers, Alieh

count + aggragation

ponding one to the second!!! Best, Alieh

delta iteration

Hello all, I need iteration number in delta iteration (or any kind of counter). Is there anyway to implement or extract it? Cheers, Alieh

delta iteration

Hello all, I need iteration number in delta iteration (or any kind of counter). Is there anyway to implement or extract it? Cheers, Alieh

delta iteration

Hello all, I need iteration number in delta iteration (or any kind of counter). Is there anyway to implement or extract it? Cheers, Alieh

gelly scatter/gather

! It seems that I have some I/O with 4 workers, but why using 8 workers I can not run the job? Best, Alieh

Flink groupBy

or example groups of size 10, 5, 5 and we have two task slots, is the process distributed in this way? task slot1: group of size 10 task slot2: two groups of size 5 Best, 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 loo

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