diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-02-11 10:05:49 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-02-11 10:05:49 -0800 |
| commit | 04786d07391c4052d6dc42ff0828a79a37bbbfdf (patch) | |
| tree | 6b05345354315bd1c06dd02e23ba527f7c25cd2e /streaming | |
| parent | c65988bdc1b75e88e6df77df0b84fc3a34c5b028 (diff) | |
| download | spark-04786d07391c4052d6dc42ff0828a79a37bbbfdf.tar.gz spark-04786d07391c4052d6dc42ff0828a79a37bbbfdf.tar.bz2 spark-04786d07391c4052d6dc42ff0828a79a37bbbfdf.zip | |
small fix
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 67d82d546f..551d4f15e4 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -810,12 +810,12 @@ public class JavaAPISuite implements Serializable { if (state.isPresent()) { out = out + state.get(); } - for (Integer v : values) { + for (Integer v: values) { out = out + v; } return Optional.of(out); } - }); + }); JavaTestUtils.attachTestOutputStream(updated); List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 3, 3); |