blank space

Author: jiyong-lee-dev

core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala

@@ -94,7 +94,7 @@ class BlockManagerMasterEndpoint(
 
   private val askThreadPool =
     ThreadUtils.newDaemonCachedThreadPool("block-manager-ask-thread-pool", 100)
-  private implicit val askExecutionContext: ExecutionContextExecutorService = 
+  private implicit val askExecutionContext: ExecutionContextExecutorService =
     ExecutionContext.fromExecutorService(askThreadPool)
 
   private val topologyMapper = {

core/src/main/scala/org/apache/spark/storage/BlockManagerStorageEndpoint.scala

@@ -38,7 +38,7 @@ class BlockManagerStorageEndpoint(
 
   private val asyncThreadPool =
     ThreadUtils.newDaemonCachedThreadPool("block-manager-storage-async-thread-pool", 100)
-  private implicit val asyncExecutionContext: ExecutionContextExecutorService = 
+  private implicit val asyncExecutionContext: ExecutionContextExecutorService =
     ExecutionContext.fromExecutorService(asyncThreadPool)
 
   // Operations that involve removing blocks may be slow and should be done asynchronously