File tree Expand file tree Collapse file tree
core/src/test/scala/org/apache/spark/executor Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -271,7 +271,7 @@ class ExecutorSuite extends SparkFunSuite
271271 }
272272
273273 private def withMockHeartbeatReceiverRef (executor : Executor )
274- (func : RpcEndpointRef => Unit ): Unit = {
274+ (func : RpcEndpointRef => Unit ): Unit = {
275275 val executorClass = classOf [Executor ]
276276 val mockReceiverRef = mock[RpcEndpointRef ]
277277 val receiverRef = executorClass.getDeclaredField(" heartbeatReceiverRef" )
@@ -282,7 +282,7 @@ class ExecutorSuite extends SparkFunSuite
282282 }
283283
284284 private def withHeartbeatExecutor (confs : (String , String )* )
285- (f : (Executor , ArrayBuffer [Heartbeat ]) => Unit ): Unit = {
285+ (f : (Executor , ArrayBuffer [Heartbeat ]) => Unit ): Unit = {
286286 val conf = new SparkConf
287287 confs.foreach { case (k, v) => conf.set(k, v) }
288288 val serializer = new JavaSerializer (conf)
You can’t perform that action at this time.
0 commit comments