Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21088#discussion_r182765201
--- Diff:
core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala ---
@@ -142,7 +142,14 @@ private[deploy] class ExecutorRunner(
private def fetchAndRunExecutor() {
try {
// Launch the process
- val builder = CommandUtils.buildProcessBuilder(appDesc.command, new
SecurityManager(conf),
+ val subsCommand = Command(appDesc.command.mainClass,
--- End diff --
How about
```
val subsOpts = appDesc.command.javaOpts.map {
opt => Utils.substituteAppNExecIds(opt, appId, execId.toString)
}
val subsCommand = appDesc.command.copy(javaOpts = subsOpts)
``` ?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
