diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-01-11 16:07:03 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-11 16:07:03 -0800 |
commit | 22d4d62420908ba3451409fa7c72cd26a009a858 (patch) | |
tree | be107c93b4164af66965e41081a177fd37030de5 | |
parent | 6510f04e4dd99163acdc15ba5fc2bcbd8ff5d338 (diff) | |
download | spark-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.
-rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala | 2 |
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") |