We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eed3390 commit 5ee4e25Copy full SHA for 5ee4e25
core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite.scala
@@ -67,10 +67,10 @@ class ClosureCleanerSuite extends FunSuite {
67
test("should clean only closures") {
68
withSpark(new SparkContext("local", "test")) { sc =>
69
val rdd = sc.makeRDD(1 to 100)
70
- intercept[IllegalArgumentException] { sc.clean(1) }
+ intercept[IllegalArgumentException] { sc.clean(new Integer(1)) }
71
intercept[IllegalArgumentException] { sc.clean("not a closure") }
72
intercept[IllegalArgumentException] { sc.clean(rdd) }
73
- sc.clean(() => 1)
+ sc.clean(() => new Integer(1))
74
sc.clean(() => "part of a closure")
75
sc.clean(() => rdd)
76
}
0 commit comments