Greg Hogan created FLINK-5891:
---------------------------------
Summary: ConnectedComponents is broken when object reuse enabled
Key: FLINK-5891
URL: https://issues.apache.org/jira/browse/FLINK-5891
Project: Flink
Issue Type: Bug
Components: Gelly
Affects Versions: 1.3.0
Reporter: Greg Hogan
{{org.apache.flink.graph.library.ConnectedComponents.CCUpdater#updateVertex}}
is storing a value from its iterator.
{{GSAConnectedComponents}} does not have this limitation.
{code}
public static final class CCUpdater<K, VV extends Comparable<VV>>
extends GatherFunction<K, VV, VV> {
@Override
public void updateVertex(Vertex<K, VV> vertex,
MessageIterator<VV> messages) throws Exception {
VV current = vertex.getValue();
VV min = current;
for (VV msg : messages) {
if (msg.compareTo(min) < 0) {
min = msg;
}
}
if (!min.equals(current)) {
setNewVertexValue(min);
}
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
