This is an automated email from the ASF dual-hosted git repository. gurwls223 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push: new 3fcbc7f [MINOR] Spelling mistake: forword -> forward 3fcbc7f is described below commit 3fcbc7fb9f7b58b040a85289a82cf551d51bac37 Author: moqimoqidea <39821951+moqimoqi...@users.noreply.github.com> AuthorDate: Wed Mar 6 16:29:07 2019 +0900 [MINOR] Spelling mistake: forword -> forward ## What changes were proposed in this pull request? Spelling mistake: forword -> forward ## How was this patch tested? This is a private function, there is no place to call this function outside of this file. Closes #23978 from moqimoqidea/master. Authored-by: moqimoqidea <39821951+moqimoqi...@users.noreply.github.com> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- .../main/scala/org/apache/spark/deploy/worker/Worker.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala index 07a9545..2fc2be5 100755 --- a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala @@ -64,7 +64,7 @@ private[deploy] class Worker( assert (port > 0) // A scheduled executor used to send messages at the specified time. - private val forwordMessageScheduler = + private val forwardMessageScheduler = ThreadUtils.newDaemonSingleThreadScheduledExecutor("worker-forward-message-scheduler") // A separated thread to clean up the workDir and the directories of finished applications. @@ -325,7 +325,7 @@ private[deploy] class Worker( if (connectionAttemptCount == INITIAL_REGISTRATION_RETRIES) { registrationRetryTimer.foreach(_.cancel(true)) registrationRetryTimer = Some( - forwordMessageScheduler.scheduleAtFixedRate(new Runnable { + forwardMessageScheduler.scheduleAtFixedRate(new Runnable { override def run(): Unit = Utils.tryLogNonFatalError { self.send(ReregisterWithMaster) } @@ -360,7 +360,7 @@ private[deploy] class Worker( registered = false registerMasterFutures = tryRegisterAllMasters() connectionAttemptCount = 0 - registrationRetryTimer = Some(forwordMessageScheduler.scheduleAtFixedRate( + registrationRetryTimer = Some(forwardMessageScheduler.scheduleAtFixedRate( new Runnable { override def run(): Unit = Utils.tryLogNonFatalError { Option(self).foreach(_.send(ReregisterWithMaster)) @@ -407,7 +407,7 @@ private[deploy] class Worker( } registered = true changeMaster(masterRef, masterWebUiUrl, masterAddress) - forwordMessageScheduler.scheduleAtFixedRate(new Runnable { + forwardMessageScheduler.scheduleAtFixedRate(new Runnable { override def run(): Unit = Utils.tryLogNonFatalError { self.send(SendHeartbeat) } @@ -415,7 +415,7 @@ private[deploy] class Worker( if (CLEANUP_ENABLED) { logInfo( s"Worker cleanup enabled; old application directories will be deleted in: $workDir") - forwordMessageScheduler.scheduleAtFixedRate(new Runnable { + forwardMessageScheduler.scheduleAtFixedRate(new Runnable { override def run(): Unit = Utils.tryLogNonFatalError { self.send(WorkDirCleanup) } @@ -668,7 +668,7 @@ private[deploy] class Worker( cleanupThreadExecutor.shutdownNow() metricsSystem.report() cancelLastRegistrationRetry() - forwordMessageScheduler.shutdownNow() + forwardMessageScheduler.shutdownNow() registerMasterThreadPool.shutdownNow() executors.values.foreach(_.kill()) drivers.values.foreach(_.kill()) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org