File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed
core/src/test/scala/org/apache/spark/rpc Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -551,7 +551,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll {
551
551
val testDurationSeconds = 30
552
552
val secondaryProp = " spark.ask.secondary.timeout"
553
553
554
- conf.set(testProp, testDurationSeconds.toString + " s" )
554
+ conf.set(testProp, s " ${testDurationSeconds} s " )
555
555
conf.set(secondaryProp, " 100s" )
556
556
557
557
// Construct RpcTimeout with a single property
@@ -570,7 +570,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll {
570
570
assert( rt3.timeoutProp.contains(defaultProp) )
571
571
572
572
// Try to construct RpcTimeout with an unconfigured property
573
- intercept[Throwable ] {
573
+ intercept[NoSuchElementException ] {
574
574
RpcTimeout (conf, " spark.ask.invalid.timeout" )
575
575
}
576
576
}
Original file line number Diff line number Diff line change @@ -24,7 +24,6 @@ import scala.language.postfixOps
24
24
25
25
import akka .actor .{Actor , ActorSystem , Props }
26
26
import akka .pattern .ask
27
-
28
27
import com .typesafe .config .{ConfigFactory , ConfigValueFactory }
29
28
30
29
import org .apache .spark .{SecurityManager , SparkConf }
You can’t perform that action at this time.
0 commit comments