Skip to content
Snippets Groups Projects
Commit cd3d937b authored by Davies Liu's avatar Davies Liu
Browse files

Revert "Once driver register successfully, stop it to connect to master."

This reverts commit 5a514b61.
parent 5a514b61
No related branches found
No related tags found
No related merge requests found
...@@ -130,7 +130,6 @@ private[spark] class AppClient( ...@@ -130,7 +130,6 @@ private[spark] class AppClient(
if (registered.get) { if (registered.get) {
registerMasterFutures.get.foreach(_.cancel(true)) registerMasterFutures.get.foreach(_.cancel(true))
registerMasterThreadPool.shutdownNow() registerMasterThreadPool.shutdownNow()
registrationRetryTimer.cancel(true)
} else if (nthRetry >= REGISTRATION_RETRIES) { } else if (nthRetry >= REGISTRATION_RETRIES) {
markDead("All masters are unresponsive! Giving up.") markDead("All masters are unresponsive! Giving up.")
} else { } else {
......
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