Hi Marc,
The CompactingHashtable is not spillable (the only operator in batch
actually that isn't), so you can only either reduce your data size or
increase your memory.
When you are using unmanaged memory, make sure the allocation of managed
memory is reduced to a minimum.
On Mon, May 29, 2017 a
Hi,
I tried to run an vertex-centric and a gather scatter iteration in Gelly and
receive an exception like
Exception in thread "main"
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$