aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2014-01-11 16:07:03 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-01-11 16:07:03 -0800
commit22d4d62420908ba3451409fa7c72cd26a009a858 (patch)
treebe107c93b4164af66965e41081a177fd37030de5 /streaming/src
parent6510f04e4dd99163acdc15ba5fc2bcbd8ff5d338 (diff)
downloadspark-22d4d62420908ba3451409fa7c72cd26a009a858.tar.gz
spark-22d4d62420908ba3451409fa7c72cd26a009a858.tar.bz2
spark-22d4d62420908ba3451409fa7c72cd26a009a858.zip
Revert "Fix one unit test that was not setting spark.cleaner.ttl"
This reverts commit 942c80b34c4642de3b0237761bc1aaeb8cbdd546.
Diffstat (limited to 'streaming/src')
-rw-r--r--streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala
index 5ccef7f461..ee6b433d1f 100644
--- a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala
+++ b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala
@@ -375,7 +375,7 @@ class BasicOperationsSuite extends TestSuiteBase {
}
test("slice") {
- val conf2 = conf.clone()
+ val conf2 = new SparkConf()
.setMaster("local[2]")
.setAppName("BasicOperationsSuite")
.set("spark.streaming.clock", "org.apache.spark.streaming.util.ManualClock")