From a351fd4aeda7d137e4cece705e25b51d7634ca63 Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Thu, 24 Oct 2013 21:16:30 -0700
Subject: [PATCH] Small spacing fix
---
.../test/java/org/apache/spark/streaming/JavaAPISuite.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
index 5a9836a415..391d7ba21d 100644
--- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
@@ -193,7 +193,7 @@ public class JavaAPISuite implements Serializable {
JavaTestUtils.attachTestOutputStream(repartitioned);
List<List<List<Integer>>> result = JavaTestUtils.runStreamsWithPartitions(ssc, 2, 2);
Assert.assertEquals(2, result.size());
- for ( List<List<Integer>> rdd : result) {
+ for (List<List<Integer>> rdd : result) {
Assert.assertEquals(4, rdd.size());
Assert.assertEquals(
10, rdd.get(0).size() + rdd.get(1).size() + rdd.get(2).size() + rdd.get(3).size());
@@ -210,7 +210,7 @@ public class JavaAPISuite implements Serializable {
JavaTestUtils.attachTestOutputStream(repartitioned);
List<List<List<Integer>>> result = JavaTestUtils.runStreamsWithPartitions(ssc, 2, 2);
Assert.assertEquals(2, result.size());
- for ( List<List<Integer>> rdd : result) {
+ for (List<List<Integer>> rdd : result) {
Assert.assertEquals(2, rdd.size());
Assert.assertEquals(10, rdd.get(0).size() + rdd.get(1).size());
}
--
GitLab