Skip to content
Snippets Groups Projects
Commit f7ac8c2b authored by Jongyoul Lee's avatar Jongyoul Lee Committed by Andrew Or
Browse files

SPARK-3223 runAsSparkUser cannot change HDFS write permission properly i...

...n mesos cluster mode

- change master newer

Author: Jongyoul Lee <jongyoul@gmail.com>

Closes #3034 from jongyoul/SPARK-3223 and squashes the following commits:

42b2ed3 [Jongyoul Lee] SPARK-3223 runAsSparkUser cannot change HDFS write permission properly in mesos cluster mode - change master newer
parent 868cd4c3
No related branches found
No related tags found
No related merge requests found
...@@ -93,7 +93,7 @@ private[spark] class CoarseMesosSchedulerBackend( ...@@ -93,7 +93,7 @@ private[spark] class CoarseMesosSchedulerBackend(
setDaemon(true) setDaemon(true)
override def run() { override def run() {
val scheduler = CoarseMesosSchedulerBackend.this val scheduler = CoarseMesosSchedulerBackend.this
val fwInfo = FrameworkInfo.newBuilder().setUser("").setName(sc.appName).build() val fwInfo = FrameworkInfo.newBuilder().setUser(sc.sparkUser).setName(sc.appName).build()
driver = new MesosSchedulerDriver(scheduler, fwInfo, master) driver = new MesosSchedulerDriver(scheduler, fwInfo, master)
try { { try { {
val ret = driver.run() val ret = driver.run()
......
...@@ -72,7 +72,7 @@ private[spark] class MesosSchedulerBackend( ...@@ -72,7 +72,7 @@ private[spark] class MesosSchedulerBackend(
setDaemon(true) setDaemon(true)
override def run() { override def run() {
val scheduler = MesosSchedulerBackend.this val scheduler = MesosSchedulerBackend.this
val fwInfo = FrameworkInfo.newBuilder().setUser("").setName(sc.appName).build() val fwInfo = FrameworkInfo.newBuilder().setUser(sc.sparkUser).setName(sc.appName).build()
driver = new MesosSchedulerDriver(scheduler, fwInfo, master) driver = new MesosSchedulerDriver(scheduler, fwInfo, master)
try { try {
val ret = driver.run() val ret = driver.run()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment