Repository: spark Updated Branches: refs/heads/master 7618896e8 -> 18f8575e0
[SPARK-23671][CORE] Fix condition to enable the SHS thread pool. Author: Marcelo Vanzin <[email protected]> Closes #20814 from vanzin/SPARK-23671. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/18f8575e Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/18f8575e Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/18f8575e Branch: refs/heads/master Commit: 18f8575e0166c6997569358d45bdae2cf45bf624 Parents: 7618896 Author: Marcelo Vanzin <[email protected]> Authored: Thu Mar 15 17:12:01 2018 -0700 Committer: Marcelo Vanzin <[email protected]> Committed: Thu Mar 15 17:12:01 2018 -0700 ---------------------------------------------------------------------- .../scala/org/apache/spark/deploy/history/FsHistoryProvider.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/18f8575e/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala index f9d0b5e..ace6d9e 100644 --- a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala +++ b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala @@ -173,7 +173,7 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock) * Fixed size thread pool to fetch and parse log files. */ private val replayExecutor: ExecutorService = { - if (Utils.isTesting) { + if (!Utils.isTesting) { ThreadUtils.newDaemonFixedThreadPool(NUM_PROCESSING_THREADS, "log-replay-executor") } else { MoreExecutors.sameThreadExecutor() --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
