MINOR: a small refactor for LogManage#shutdown (#9680)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
apache · Dec 4, 2020 · df0c52e · df0c52e
1 parent 4cc6d20
commit df0c52e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala
@@ -479,14 +479,14 @@ class LogManager(logDirs: Seq[File],
 
     try {
       for ((dir, dirJobs) <- jobs) {
-        val hasErrors = dirJobs.map { future =>
+        val hasErrors = dirJobs.exists  { future =>
           Try(future.get) match {
             case Success(_) => false
             case Failure(e) =>
               warn(s"There was an error in one of the threads during LogManager shutdown: ${e.getCause}")
               true
           }
-        }.contains(true)
+        }
 
         if (!hasErrors) {
           val logs = logsInDir(localLogsByDir, dir)