diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java
index 26ac82b71ace567872eb8cfd0ab5755ff55f1ae2..4cf9d115ae9aad674f838a08cf261e6af23313d1 100644
--- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java
@@ -511,16 +511,16 @@ public class JavaAPISuite implements Serializable {
     List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream;
 
     List<List<Tuple2<Integer, String>>> expected = Arrays.asList(
-            Arrays.asList(
-                    new Tuple2<Integer, String>(1, "california"),
-                    new Tuple2<Integer, String>(3, "california"),
-                    new Tuple2<Integer, String>(4, "new york"),
-                    new Tuple2<Integer, String>(1, "new york")),
-            Arrays.asList(
-                    new Tuple2<Integer, String>(5, "california"),
-                    new Tuple2<Integer, String>(5, "california"),
-                    new Tuple2<Integer, String>(3, "new york"),
-                    new Tuple2<Integer, String>(1, "new york")));
+        Arrays.asList(
+                new Tuple2<Integer, String>(1, "california"),
+                new Tuple2<Integer, String>(3, "california"),
+                new Tuple2<Integer, String>(4, "new york"),
+                new Tuple2<Integer, String>(1, "new york")),
+        Arrays.asList(
+                new Tuple2<Integer, String>(5, "california"),
+                new Tuple2<Integer, String>(5, "california"),
+                new Tuple2<Integer, String>(3, "new york"),
+                new Tuple2<Integer, String>(1, "new york")));
 
     JavaDStream<Tuple2<String, Integer>> stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 1);
     JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream);