spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From van...@apache.org
Subject spark git commit: [SPARK-23671][CORE] Fix condition to enable the SHS thread pool.
Date Fri, 16 Mar 2018 00:12:30 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-2.3 2e1e274ed -> 52a52d5d2


[SPARK-23671][CORE] Fix condition to enable the SHS thread pool.

Author: Marcelo Vanzin <vanzin@cloudera.com>

Closes #20814 from vanzin/SPARK-23671.

(cherry picked from commit 18f8575e0166c6997569358d45bdae2cf45bf624)
Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/52a52d5d
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/52a52d5d
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/52a52d5d

Branch: refs/heads/branch-2.3
Commit: 52a52d5d26fc1650e788eec62ce478c76f627470
Parents: 2e1e274
Author: Marcelo Vanzin <vanzin@cloudera.com>
Authored: Thu Mar 15 17:12:01 2018 -0700
Committer: Marcelo Vanzin <vanzin@cloudera.com>
Committed: Thu Mar 15 17:12:24 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/52a52d5d/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


Mime
View raw message