spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject git commit: HOTFIX: Disable actor input stream test.
Date Mon, 07 Apr 2014 19:47:34 GMT
Repository: spark
Updated Branches:
  refs/heads/master 9dd8b9166 -> 2a2ca48be


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.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2a2ca48b
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2a2ca48b
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2a2ca48b

Branch: refs/heads/master
Commit: 2a2ca48be61ed0d72c4347e1c042a264b94db3e8
Parents: 9dd8b91
Author: Patrick Wendell <pwendell@gmail.com>
Authored: Mon Apr 7 12:47:27 2014 -0700
Committer: Patrick Wendell <pwendell@gmail.com>
Committed: Mon Apr 7 12:47:27 2014 -0700

----------------------------------------------------------------------
 .../scala/org/apache/spark/streaming/InputStreamsSuite.scala     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/2a2ca48b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala
----------------------------------------------------------------------
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 7df2062..389b23d 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


Mime
View raw message