Skip to content
This repository was archived by the owner on Oct 23, 2024. It is now read-only.

[DCOS-46585] Fix supervised driver retry logic for outdated tasks #46

Merged
samvantran merged 12 commits into from
Jan 18, 2019
Merged

[DCOS-46585] Fix supervised driver retry logic for outdated tasks #46

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
8ebff3b
Fix scalastyle error for multiline comment
samvantran Jan 4, 2019
a05c2f1
WIP: checking if task already relaunched via ZK
samvantran Jan 15, 2019
c43545b
WIP updating test to reflect IRL scenario
samvantran Jan 16, 2019
798c3c8
Bingo
samvantran Jan 16, 2019
70ba913
Cleanup log messages
samvantran Jan 16, 2019
473bf1b
Simplify the logic
samvantran Jan 17, 2019
712d3fd
Cleanup + revert accidental changes
samvantran Jan 17, 2019
58f3f74
Track retriedDrivers via HashSet
samvantran Jan 17, 2019
b7b25e7
Merge branch 'custom-branch-2.3.x' into 46585-duplicate-retries
samvantran Jan 17, 2019
361699d
Better solution: check in launched and pending drivers
samvantran Jan 17, 2019
b2a694d
Add scaladoc for taskIsOutdated method
samvantran Jan 18, 2019
4b65983
Merge branch 'custom-branch-2.3.x' into 46585-duplicate-retries
samvantran Jan 18, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Fix scalastyle error for multiline comment
  • Loading branch information
@samvantran
samvantran committed Jan 4, 2019
commit 8ebff3b6ce63d52e12bea780db02cb059cfdc757
4 changes: 2 additions & 2 deletions core/src/main/scala/org/apache/spark/SecurityManager.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -523,8 +523,8 @@ private[spark] class SecurityManager(
}

/**
* Trying to find a File Based Secret with path specified in SPARK_AUTH_SECRET_CONF
*/
* Trying to find a File Based Secret with path specified in SPARK_AUTH_SECRET_CONF
*/
def getFileBasedSecret(): Option[String] = {
sparkConf
.getOption(SPARK_AUTH_SECRET_CONF)
Expand Down