diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-10-24 15:17:26 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-10-24 15:17:26 -0700 |
| commit | e962a6e6ee8d8ef9d1245d85616fe50554f7f689 (patch) | |
| tree | 363bbf6ca43836f1b283c37ea987c2b6000cf2c6 /streaming | |
| parent | 0400aba1c0fac298c024dee4fb4be23328f07e35 (diff) | |
| download | spark-e962a6e6ee8d8ef9d1245d85616fe50554f7f689.tar.gz spark-e962a6e6ee8d8ef9d1245d85616fe50554f7f689.tar.bz2 spark-e962a6e6ee8d8ef9d1245d85616fe50554f7f689.zip | |
Fixed accidental bug.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 2 |
1 files changed, 1 insertions, 1 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 f588afe90c..5d48908667 100644 --- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java @@ -332,7 +332,7 @@ public class JavaAPISuite implements Serializable { } }); } - ); + }); JavaTestUtils.attachTestOutputStream(transformed); List<List<Integer>> result = JavaTestUtils.runStreams(ssc, 3, 3); |