diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 21:16:30 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 21:16:30 -0700 |
| commit | a351fd4aeda7d137e4cece705e25b51d7634ca63 (patch) | |
| tree | 8720fdc42ef142d4a3cd5dea19ee13122db20ed1 /streaming | |
| parent | 31e92b72e31910be1694c348ab5de8b14f2df44b (diff) | |
| download | spark-a351fd4aeda7d137e4cece705e25b51d7634ca63.tar.gz spark-a351fd4aeda7d137e4cece705e25b51d7634ca63.tar.bz2 spark-a351fd4aeda7d137e4cece705e25b51d7634ca63.zip | |
Small spacing fix
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 4 |
1 files 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()); } |