You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by va...@apache.org on 2018/03/16 00:12:07 UTC
spark git commit: [SPARK-23671][CORE] Fix condition to enable the SHS
thread pool.
Repository: spark
Updated Branches:
refs/heads/master 7618896e8 -> 18f8575e0
[SPARK-23671][CORE] Fix condition to enable the SHS thread pool.
Author: Marcelo Vanzin <va...@cloudera.com>
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 <va...@cloudera.com>
Authored: Thu Mar 15 17:12:01 2018 -0700
Committer: Marcelo Vanzin <va...@cloudera.com>
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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org