Skip to content

Commit b0c3ac9

Browse files
committed
Fix the variable types
1 parent 84324fb commit b0c3ac9

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -967,7 +967,7 @@ public Integer call(Tuple2<String, Integer> in) throws Exception {
967967
});
968968

969969
JavaTestUtils.attachTestOutputStream(reversed);
970-
List<List<Tuple2<Integer, String>>> result = JavaTestUtils.runStreams(ssc, 2, 2);
970+
List<List<Integer>> result = JavaTestUtils.runStreams(ssc, 2, 2);
971971

972972
Assert.assertEquals(expected, result);
973973
}
@@ -1010,7 +1010,7 @@ public Iterable<Tuple2<Integer, String>> call(Tuple2<String, Integer> in) throws
10101010
}
10111011
});
10121012
JavaTestUtils.attachTestOutputStream(flatMapped);
1013-
List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 2, 2);
1013+
List<List<Tuple2<Integer, String>>> result = JavaTestUtils.runStreams(ssc, 2, 2);
10141014

10151015
Assert.assertEquals(expected, result);
10161016
}
@@ -1338,7 +1338,7 @@ public JavaPairRDD<Integer, Integer> call(JavaPairRDD<Integer, Integer> in) thro
13381338
});
13391339

13401340
JavaTestUtils.attachTestOutputStream(sorted);
1341-
List<List<Tuple2<String, String>>> result = JavaTestUtils.runStreams(ssc, 2, 2);
1341+
List<List<Tuple2<Integer, Integer>>> result = JavaTestUtils.runStreams(ssc, 2, 2);
13421342

13431343
Assert.assertEquals(expected, result);
13441344
}

0 commit comments

Comments
 (0)