diff options
| author | tdas <tathagata.das1565@gmail.com> | 2012-11-08 11:17:57 +0000 |
|---|---|---|
| committer | tdas <tathagata.das1565@gmail.com> | 2012-11-08 11:17:57 +0000 |
| commit | cc2a65f54715ff0990d5873d50eec0dedf64d409 (patch) | |
| tree | f953a07fc54b5257c63a1e11f46465da16813eb3 /streaming | |
| parent | fc3d0b602a08fdd182c2138506d1cd9952631f95 (diff) | |
| download | spark-cc2a65f54715ff0990d5873d50eec0dedf64d409.tar.gz spark-cc2a65f54715ff0990d5873d50eec0dedf64d409.tar.bz2 spark-cc2a65f54715ff0990d5873d50eec0dedf64d409.zip | |
Fixed bug in InputStreamsSuite
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala index c17254b809..8f892baab1 100644 --- a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala @@ -12,6 +12,8 @@ import org.apache.commons.io.FileUtils class InputStreamsSuite extends TestSuiteBase { + + System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock") test("network input stream") { // Start the server |