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 {
551551 val testDurationSeconds = 30
552552 val secondaryProp = " spark.ask.secondary.timeout"
553553
554- conf.set(testProp, testDurationSeconds.toString + " s" )
554+ conf.set(testProp, s " ${testDurationSeconds} s " )
555555 conf.set(secondaryProp, " 100s" )
556556
557557 // Construct RpcTimeout with a single property
@@ -570,7 +570,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll {
570570 assert( rt3.timeoutProp.contains(defaultProp) )
571571
572572 // Try to construct RpcTimeout with an unconfigured property
573- intercept[Throwable ] {
573+ intercept[NoSuchElementException ] {
574574 RpcTimeout (conf, " spark.ask.invalid.timeout" )
575575 }
576576 }
Original file line number Diff line number Diff line change @@ -24,7 +24,6 @@ import scala.language.postfixOps
2424
2525import akka .actor .{Actor , ActorSystem , Props }
2626import akka .pattern .ask
27-
2827import com .typesafe .config .{ConfigFactory , ConfigValueFactory }
2928
3029import org .apache .spark .{SecurityManager , SparkConf }
You can’t perform that action at this time.
0 commit comments