aboutsummaryrefslogtreecommitdiff
path: root/extras
diff options
context:
space:
mode:
authorEvan Chen <chene@us.ibm.com>2015-12-17 14:22:30 -0800
committerShixiong Zhu <shixiong@databricks.com>2015-12-17 14:22:30 -0800
commited6ebda5c898bad76194fe3a090bef5a14f861c2 (patch)
tree3eadad21aa344ddb82df903838ede73108d6fead /extras
parente096a652b92fc64a7b3457cd0766ab324bcc980b (diff)
downloadspark-ed6ebda5c898bad76194fe3a090bef5a14f861c2.tar.gz
spark-ed6ebda5c898bad76194fe3a090bef5a14f861c2.tar.bz2
spark-ed6ebda5c898bad76194fe3a090bef5a14f861c2.zip
[SPARK-12376][TESTS] Spark Streaming Java8APISuite fails in assertOrderInvariantEquals method
org.apache.spark.streaming.Java8APISuite.java is failing due to trying to sort immutable list in assertOrderInvariantEquals method. Author: Evan Chen <chene@us.ibm.com> Closes #10336 from evanyc15/SPARK-12376-StreamingJavaAPISuite.
Diffstat (limited to 'extras')
-rw-r--r--extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java11
1 files changed, 8 insertions, 3 deletions
diff --git a/extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java b/extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java
index 89e0c7fdf7..e8a0dfc0f0 100644
--- a/extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java
+++ b/extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java
@@ -439,9 +439,14 @@ public class Java8APISuite extends LocalJavaStreamingContext implements Serializ
*/
public static <T extends Comparable<T>> void assertOrderInvariantEquals(
List<List<T>> expected, List<List<T>> actual) {
- expected.forEach((List<T> list) -> Collections.sort(list));
- actual.forEach((List<T> list) -> Collections.sort(list));
- Assert.assertEquals(expected, actual);
+ expected.forEach(list -> Collections.sort(list));
+ List<List<T>> sortedActual = new ArrayList<>();
+ actual.forEach(list -> {
+ List<T> sortedList = new ArrayList<>(list);
+ Collections.sort(sortedList);
+ sortedActual.add(sortedList);
+ });
+ Assert.assertEquals(expected, sortedActual);
}
@Test