flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Greg Hogan (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5891) ConnectedComponents is broken when object reuse enabled
Date Wed, 22 Feb 2017 21:26:44 GMT
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)

Mime
View raw message