Hi Fabian,
at first, sorry for the late answer. The given execution plan was created
after 20 minutes, only one vertex centric iteration is missing. I can
optimize the program because some operators are only needed to create
intermediate debug results, still, it's not enough to run as one Flink j
Hello Flink community,
I created a slightly long batch workflow for my use case of clustering
vertices using
Flink and Gelly. Executing each of the workflow parts individually (and
write
intermediate results to disk) works as suspected.
When combining workflow parts to longer jobs, I noticed that