print availableProcessors

apache · Aug 11, 2020 · 4e1d8ec · 4e1d8ec
1 parent fe5f891
commit 4e1d8ec
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/rpc/netty/MessageLoop.scala b/core/src/main/scala/org/apache/spark/rpc/netty/MessageLoop.scala
@@ -109,7 +109,15 @@ private class SharedMessageLoop(
 
   private def getNumOfThreads(conf: SparkConf): Int = {
     val availableCores =
-      if (numUsableCores > 0) numUsableCores else Runtime.getRuntime.availableProcessors()
+      if (numUsableCores > 0) {
+        numUsableCores
+      } else {
+        val processors = Runtime.getRuntime.availableProcessors()
+        // scalastyle:off
+        println(s"availableProcessors=$processors")
+        // scalastyle:on
+        processors
+      }
 
     val modNumThreads = conf.get(RPC_NETTY_DISPATCHER_NUM_THREADS)
       .getOrElse(math.max(2, availableCores))