[FLINK-1514] [gelly] suppressed warnings in several places; adjusted …

…tests

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java

@@ -85,7 +85,7 @@ public Double map(Long id) {
 				return 0.0;
 			}
 			else {
-				return Double.MAX_VALUE;
+				return Double.POSITIVE_INFINITY;
 			}
 		}
 	}

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java

@@ -23,6 +23,7 @@
 
 import java.io.Serializable;
 
+@SuppressWarnings("serial")
 public abstract class ApplyFunction<VV extends Serializable, EV extends Serializable, M> implements Serializable {
 
 	public abstract void apply(M message, VV vertexValue);
@@ -54,6 +55,7 @@ public void setResult(VV result) {
 	//  Internal methods
 	// --------------------------------------------------------------------------------------------
 
+	@SuppressWarnings("unused")
 	private IterationRuntimeContext runtimeContext;
 
 	private Collector<VV> out;

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java

@@ -22,6 +22,7 @@
 
 import java.io.Serializable;
 
+@SuppressWarnings("serial")
 public abstract class GatherFunction<VV extends Serializable, EV extends Serializable, M> implements Serializable {
 
 	public abstract M gather(Neighbor<VV, EV> neighbor);
@@ -44,6 +45,7 @@ public abstract class GatherFunction<VV extends Serializable, EV extends Seriali
 	//  Internal methods
 	// --------------------------------------------------------------------------------------------
 
+	@SuppressWarnings("unused")
 	private IterationRuntimeContext runtimeContext;
 
 	public void init(IterationRuntimeContext iterationRuntimeContext) {

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java

@@ -165,6 +165,7 @@ GatherSumApplyIteration<K, VV, EV, M> withEdges(DataSet<Edge<K, EV>> edges,
 	//  Wrapping UDFs
 	// --------------------------------------------------------------------------------------------
 
+	@SuppressWarnings("serial")
 	private static final class GatherUdf<K extends Comparable<K> & Serializable, VV extends Serializable,
 			EV extends Serializable, M> extends RichMapFunction<Tuple2<Vertex<K, VV>, Edge<K, EV>>,
 			Tuple2<K, M>> implements ResultTypeQueryable<Tuple2<K, M>> {
@@ -206,6 +207,7 @@ public TypeInformation<Tuple2<K, M>> getProducedType() {
 		}
 	}
 
+	@SuppressWarnings("serial")
 	private static final class SumUdf<K extends Comparable<K> & Serializable, VV extends Serializable,
 			EV extends Serializable, M> extends RichReduceFunction<Tuple2<K, M>>
 			implements ResultTypeQueryable<Tuple2<K, M>>{
@@ -244,6 +246,7 @@ public TypeInformation<Tuple2<K, M>> getProducedType() {
 		}
 	}
 
+	@SuppressWarnings("serial")
 	private static final class ApplyUdf<K extends Comparable<K> & Serializable,
 			VV extends Serializable, EV extends Serializable, M> extends RichFlatJoinFunction<Tuple2<K, M>,
 			Vertex<K, VV>, Vertex<K, VV>> implements ResultTypeQueryable<Vertex<K, VV>> {

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java

@@ -28,6 +28,7 @@
  * @param <VV> the vertex value type
  * @param <EV> the edge value type
  */
+@SuppressWarnings("serial")
 public class Neighbor<VV extends Serializable, EV extends Serializable>
 		extends Tuple2<VV, EV> {
 

flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java

@@ -22,6 +22,7 @@
 
 import java.io.Serializable;
 
+@SuppressWarnings("serial")
 public abstract class SumFunction<VV extends Serializable, EV extends Serializable, M> implements Serializable {
 
 	public abstract M sum(M arg0, M arg1);
@@ -44,6 +45,7 @@ public abstract class SumFunction<VV extends Serializable, EV extends Serializab
 	//  Internal methods
 	// --------------------------------------------------------------------------------------------
 
+	@SuppressWarnings("unused")
 	private IterationRuntimeContext runtimeContext;
 
 	public void init(IterationRuntimeContext iterationRuntimeContext) {

flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java

@@ -68,7 +68,7 @@ public void after() throws Exception{
 	// --------------------------------------------------------------------------------------------
 
 	@Test
-	public void testGreedyGraphColoring() throws Exception {
+	public void testConnectedComponents() throws Exception {
 		GSAConnectedComponentsExample.main(new String[]{edgesPath, resultPath, "16"});
 		expectedResult = "1 1\n" +
 				"2 1\n" +
@@ -86,7 +86,7 @@ public void testGreedyGraphColoring() throws Exception {
 
 	@Test
 	public void testSingleSourceShortestPath() throws Exception {
-		GSASingleSourceShortestPathsExample.main(new String[]{edgesPath, resultPath, "1", "16"});
+		GSASingleSourceShortestPathsExample.main(new String[]{"1", edgesPath, resultPath, "16"});
 		expectedResult = "1 0.0\n" +
 				"2 12.0\n" +
 				"3 13.0\n" +
@@ -101,12 +101,12 @@ public void testSingleSourceShortestPath() throws Exception {
 	//  Sample data
 	// --------------------------------------------------------------------------------------------
 
-	private static final String EDGES = "1 2 12.0\n" +
-			"1 3 13.0\n" +
-			"2 3 23.0\n" +
-			"3 4 34.0\n" +
-			"3 5 35.0\n" +
-			"4 5 45.0\n" +
-			"5 1 51.0\n" +
-			"6 7 67.0\n";
+	private static final String EDGES = "1	2	12.0\n" +
+			"1	3	13.0\n" +
+			"2	3	23.0\n" +
+			"3	4	34.0\n" +
+			"3	5	35.0\n" +
+			"4	5	45.0\n" +
+			"5	1	51.0\n" +
+			"6	7	67.0\n";
 }