-
Notifications
You must be signed in to change notification settings - Fork 118
Support specify CPU cores for driver pod #207
Support specify CPU cores for driver pod #207
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
@@ -64,6 +64,9 @@ private[spark] class Client( | |||
.map(_.split(",")) | |||
.getOrElse(Array.empty[String]) | |||
|
|||
// CPU settings | |||
private val driverCpuCores = sparkConf.getOption("spark.driver.cores").getOrElse("1") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If there's a config like org.apache.spark.internal.config.DRIVER_MEMORY
for driver cores that would be good to use, if not no need to make one
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah, there's not a config like org.apache.spark.internal.config.DRIVER_MEMORY
. IMO, we should change the spark core code less as far as possible before we merge to spark master branch, and change kubernetes scheduler will be better.
I am not involved on this project, you have the wrong developer. |
I think foxish meant @mccheah (note the extra 'c') |
Thanks for the contribution @hustcat ! |
Support specify CPU cores for driver pod, such as:
Fix #205 .