[SPARK-16095][YARN] Yarn cluster mode should report correct state to SparkLauncher#13962
[SPARK-16095][YARN] Yarn cluster mode should report correct state to SparkLauncher#13962renozhang wants to merge 5 commits intoapache:masterfrom
Conversation
|
Test build #61438 has finished for PR 13962 at commit
|
| } | ||
| } | ||
|
|
||
| private object YarnClusterDriver extends Logging with Matchers { |
There was a problem hiding this comment.
In current YarnClusterDriver, it already has failures but not failed the test.
On line 340: calling sc.parallelize() after sc.stop() will fail app with error
ApplicationMaster: Final app status: FAILED, exitCode: 15, (reason: User class threw exception: java.lang.IllegalStateException: Cannot call methods on a stopped SparkContext.
|
Test build #61442 has finished for PR 13962 at commit
|
|
Test build #61474 has finished for PR 13962 at commit
|
|
Looks good to me, CC @vanzin about |
| case YarnApplicationState.FINISHED => | ||
| reportLauncherState(SparkAppHandle.State.FINISHED) | ||
| report.getFinalApplicationStatus match { | ||
| case FinalApplicationStatus.FAILED => |
There was a problem hiding this comment.
How about also handling KILLED? In case the app is killed via YARN UI / CLI.
|
Test build #61619 has finished for PR 13962 at commit
|
|
@vanzin I've updated code and comments. |
|
LGTM. Merging to master / 2.0 (fix is simple enough and I'd rather have the whole 2.x line behave the same here). |
…SparkLauncher ## What changes were proposed in this pull request? Yarn cluster mode should return correct state for SparkLauncher ## How was this patch tested? unit test Author: peng.zhang <peng.zhang@xiaomi.com> Closes #13962 from renozhang/SPARK-16095-spark-launcher-wrong-state. (cherry picked from commit bad0f7d) Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>
What changes were proposed in this pull request?
Yarn cluster mode should return correct state for SparkLauncher
How was this patch tested?
unit test