[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

[Xingcan Cui (JIRA)]

Title: Message Title

Xingcan Cui commented on FLINK-1526   Re: Add Minimum Spanning Tree library method and example Hi Vasia Kalavri, thanks for your explanation. I got the problem. It seems that Flink still lack a cache() like method for its Dataset and that's why during each iteration the job can only run from the very beginning. As you said before, we really can implement the algorithm without an intermediate result cache support (maybe move all steps to a single vertex-centric iteration and store the edge values in vertices). However, the codes will be ugly then and that must not be a good "example" for the Gelly lib. Therefore, I'm afraid the issue should be shelved again until the underlayer provide more supportive. What do you think? As for the "no value updates", it comes from https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/libs/gelly/iterative_graph_processing.html. I think it's better to give a more clear explanation of the end conditions for each kind of iteration. Sorry for making bold. Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)