Skip to content

Commit 18f8575

Browse files
author
Marcelo Vanzin
committed
[SPARK-23671][CORE] Fix condition to enable the SHS thread pool.
Author: Marcelo Vanzin <[email protected]> Closes #20814 from vanzin/SPARK-23671.
1 parent 7618896 commit 18f8575

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
173173
* Fixed size thread pool to fetch and parse log files.
174174
*/
175175
private val replayExecutor: ExecutorService = {
176-
if (Utils.isTesting) {
176+
if (!Utils.isTesting) {
177177
ThreadUtils.newDaemonFixedThreadPool(NUM_PROCESSING_THREADS, "log-replay-executor")
178178
} else {
179179
MoreExecutors.sameThreadExecutor()

0 commit comments

Comments
 (0)