Skip to content

Commit 8e77408

Browse files
committed
Fix test failed
1 parent c1dfda1 commit 8e77408

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,16 +49,16 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, scheduler: TaskSchedule
4949

5050
val executorLastSeen = new mutable.HashMap[String, Long]
5151

52-
val slaveTimeout = conf.getLong("spark.executor.heartbeat.timeoutMs", 120 * 1000)
52+
val slaveTimeout = sc.conf.getLong("spark.executor.heartbeat.timeoutMs", 120 * 1000)
5353

54-
val checkTimeoutInterval = conf.getLong("spark.executor.heartbeat.timeoutIntervalMs", 60000)
54+
val checkTimeoutInterval = sc.conf.getLong("spark.executor.heartbeat.timeoutIntervalMs", 60000)
5555

5656
var timeoutCheckingTask: Cancellable = null
5757

5858
override def preStart() {
5959
import context.dispatcher
6060
timeoutCheckingTask = context.system.scheduler.schedule(0.seconds,
61-
checkTimeoutInterval.milliseconds, self, ExpireDeadHosts)
61+
checkTimeoutInterval.milliseconds, self, ExpireDeadHosts)
6262
super.preStart
6363
}
6464

0 commit comments

Comments
 (0)