Hi Stephan,
I tried the solution with DeltaIteration#setSolutionSetUnManaged(),
unfortunatelly the error is still there... Even when I try to run it with
just one iteration... Also, I am not sure that the job can be broken into
subparts in this particular case.
Any other suggestions would be appr
This is actually a problem of the number of memory segments available to
the hash table for the solution set.
For complex pipelines, memory currently gets too fragmented.
There are two workarounds, until we do the dynamic memory management, or
break it into shorter pipelines: Break the job up int
Hi Andra,
have you tried increasing the number of network buffers in your cluster?
You can control by the configuration value:
taskmanager.network.numberOfBuffers: #numberBuffers
Greets,
Till
On Mon, Feb 9, 2015 at 9:56 AM, Andra Lungu wrote:
> Hello everyone,
>
> I am implementing a graph a
Hello everyone,
I am implementing a graph algorithm as part of a course and I will also add
it to the Flink- Gelly examples.
My problem is that I started developing it in the Gelly repository, which
runs on flink 0.9. It works like a charm there, but in order to test in on
a cluster to see its rea
