use DurationConvertions etc

xueyumusic · xueyumusic · commit a8dc241d0d9a · 2018-06-15T19:14:40.000+08:00
diff --git a/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala b/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala
@@ -636,7 +636,7 @@ private[spark] class MesosCoarseGrainedSchedulerBackend(
             externalShufflePort,
             sc.conf.getTimeAsMs("spark.storage.blockManagerSlaveTimeoutMs",
               s"${sc.conf.getTimeAsSeconds("spark.network.timeout", "120s").seconds.toMillis}ms"),
-            sc.conf.getTimeAsSeconds("spark.executor.heartbeatInterval", "10s") * 1000L)
+            sc.conf.getTimeAsSeconds("spark.executor.heartbeatInterval", "10s").seconds.toMillis)
         slave.shuffleRegistered = true
       }
 

Original file line number	Diff line number	Diff line change
`@@ -636,7 +636,7 @@ private[spark] class MesosCoarseGrainedSchedulerBackend(`
`636`	`636`	`externalShufflePort,`
`637`	`637`	`sc.conf.getTimeAsMs("spark.storage.blockManagerSlaveTimeoutMs",`
`638`	`638`	`s"${sc.conf.getTimeAsSeconds("spark.network.timeout", "120s").seconds.toMillis}ms"),`
`639`		`- sc.conf.getTimeAsSeconds("spark.executor.heartbeatInterval", "10s") * 1000L)`
	`639`	`+ sc.conf.getTimeAsSeconds("spark.executor.heartbeatInterval", "10s").seconds.toMillis)`
`640`	`640`	`slave.shuffleRegistered = true`
`641`	`641`	`}`
`642`	`642`