diff options
Diffstat (limited to 'streaming/src/test/scala/spark/streaming/FailureSuite.scala')
| -rw-r--r-- | streaming/src/test/scala/spark/streaming/FailureSuite.scala | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/streaming/src/test/scala/spark/streaming/FailureSuite.scala b/streaming/src/test/scala/spark/streaming/FailureSuite.scala deleted file mode 100644 index a5fa7ab92d..0000000000 --- a/streaming/src/test/scala/spark/streaming/FailureSuite.scala +++ /dev/null @@ -1,40 +0,0 @@ -package spark.streaming - -import spark.Logging -import spark.streaming.util.MasterFailureTest -import StreamingContext._ - -import org.scalatest.{FunSuite, BeforeAndAfter} -import com.google.common.io.Files -import java.io.File -import org.apache.commons.io.FileUtils -import collection.mutable.ArrayBuffer - - -/** - * This testsuite tests master failures at random times while the stream is running using - * the real clock. - */ -class FailureSuite extends FunSuite with BeforeAndAfter with Logging { - - var directory = "FailureSuite" - val numBatches = 30 - val batchDuration = Milliseconds(1000) - - before { - FileUtils.deleteDirectory(new File(directory)) - } - - after { - FileUtils.deleteDirectory(new File(directory)) - } - - test("multiple failures with map") { - MasterFailureTest.testMap(directory, numBatches, batchDuration) - } - - test("multiple failures with updateStateByKey") { - MasterFailureTest.testUpdateStateByKey(directory, numBatches, batchDuration) - } -} - |