flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [13/16] [FLINK-1023] Switch group-at-a-time function to java.lang.Iterable (from java.util.Iterator) Iterables over transient data throw an TraversableOnceException when iterated over again.
Date Fri, 01 Aug 2014 00:36:54 GMT
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/72d7b862/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java
b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java
index 52f14c6..07fd658 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java
@@ -79,7 +79,7 @@ public class WorksetConnectedComponents implements Program, ProgramDescription
{
 	}
 	
 	/**
-	 * Minimum aggregation over (Vertex-ID, Component-ID) pairs, selecting the pair with the
smallest Comonent-ID.
+	 * Minimum aggregation over (Vertex-ID, Component-ID) pairs, selecting the pair with the
smallest Component-ID.
 	 */
 	@Combinable
 	@ConstantFields(0)


Mime
View raw message