breaking the pipe line

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 are

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

e executed again. I do not like to use delta or bulk iteration. 2nd question: Using the "Aggregations.Max" on a DataSet of Tuple2 on the second field, I observed that the second field is the real maximum of the whole dataset while the first field is not the corresponding 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 wrote: Hi Alieh, Could you share you code so that we can have a look?From the information you provide we cannot

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

Send to all in gelly scatter

Hi Is it possible to send a message to all vertices in gelly scatter? How the Ids of all vertices can be found out? 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