[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17336797#comment-17336797 ]
Flink Jira Bot commented on FLINK-5891: --------------------------------------- This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this ticket is actually Major, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > 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: Library / Graph Processing (Gelly) > Affects Versions: 1.3.0 > Reporter: Greg Hogan > Priority: Major > Labels: stale-major > > {{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 (v8.3.4#803005)