diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-04-07 12:47:27 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-07 12:47:27 -0700 |
| commit | 2a2ca48be61ed0d72c4347e1c042a264b94db3e8 (patch) | |
| tree | 319a6a3868cda0406356509731b4cf1b7d1e5f49 /streaming | |
| parent | 9dd8b9166225cbcfcab1f39268244c2feb42a658 (diff) | |
| download | spark-2a2ca48be61ed0d72c4347e1c042a264b94db3e8.tar.gz spark-2a2ca48be61ed0d72c4347e1c042a264b94db3e8.tar.bz2 spark-2a2ca48be61ed0d72c4347e1c042a264b94db3e8.zip | |
HOTFIX: Disable actor input stream test.
This test makes incorrect assumptions about the behavior of Thread.sleep().
Author: Patrick Wendell <pwendell@gmail.com>
Closes #347 from pwendell/stream-tests and squashes the following commits:
10e09e0 [Patrick Wendell] HOTFIX: Disable actor input stream.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala index 7df206241b..389b23d4d5 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala @@ -144,8 +144,8 @@ class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter { conf.set("spark.streaming.clock", "org.apache.spark.streaming.util.ManualClock") } - - test("actor input stream") { + // TODO: This test makes assumptions about Thread.sleep() and is flaky + ignore("actor input stream") { // Start the server val testServer = new TestServer() val port = testServer.port |