Removing blocking keyword so as to prevent a large number of threads …

…being spawned (linkedin#362)
pralabhkumar · Aug 31, 2018 · 7edce7c · 7edce7c
1 parent cbc6375
commit 7edce7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/com/linkedin/drelephant/spark/fetchers/SparkLogClient.scala b/app/com/linkedin/drelephant/spark/fetchers/SparkLogClient.scala
@@ -62,7 +62,7 @@ class SparkLogClient(hadoopConfiguration: Configuration, sparkConf: SparkConf, e
     val (eventLogPath, eventLogCodec) =
       sparkUtils.pathAndCodecforEventLog(sparkConf, eventLogFileSystem, baseEventLogPath, appId, attemptId)
 
-    Future {
+    Future { 
         sparkUtils.withEventLog(eventLogFileSystem, eventLogPath, eventLogCodec)(findDerivedData(_))
     }
   }