[jira] [Created] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[Shang Yuanchun (Jira)]

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)