Hendrik/xgboost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[jvm-packages] Fixed the sanity check for parameter 'nthread' against 'spark.task.cpus'. (#1582)

Browse Source
This commit is contained in:
Xin Yin 2016-09-16 11:31:35 -04:00 committed by Nan Zhu
parent 4041c39090
commit 7245145712
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jvm-packages/xgboost4j-spark/src/main/scala/ml/dmlc/xgboost4j/scala/spark/XGBoost.scala
View File

@ -188,9 +188,9 @@ object XGBoost extends Serializable {
implicit val sc = trainingData.sparkContext
var overridedConfMap = configMap
if (overridedConfMap.contains("nthread")) {
val nThread = overridedConfMap("nthread")
val coresPerTask = sc.getConf.get("spark.task.cpus", "1")
require(nThread.toString <= coresPerTask,
val nThread = overridedConfMap("nthread").toString.toInt
val coresPerTask = sc.getConf.get("spark.task.cpus", "1").toInt
require(nThread <= coresPerTask,
s"the nthread configuration ($nThread) must be no larger than " +
s"spark.task.cpus ($coresPerTask)")
} else {