flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chiwanp...@apache.org
Subject [2/3] flink git commit: [hotfix] Fix typo 'JobManger'
Date Fri, 18 Mar 2016 03:08:41 GMT
[hotfix] Fix typo 'JobManger'

This closes #1812.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f42f4da3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f42f4da3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f42f4da3

Branch: refs/heads/master
Commit: f42f4da34d405e489120a8fb20554003aa6c380b
Parents: d107105
Author: Stefano Baghino <stefano.baghino@radicalbit.io>
Authored: Thu Mar 17 12:58:12 2016 +0100
Committer: Chiwan Park <chiwanpark@apache.org>
Committed: Fri Mar 18 12:03:02 2016 +0900

----------------------------------------------------------------------
 .../org/apache/flink/runtime/jobmanager/JobManager.scala     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f42f4da3/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
index 95305f3..518336c 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
@@ -1858,7 +1858,7 @@ object JobManager {
 
     val webMonitor: Option[WebMonitor] =
       if (configuration.getInteger(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, 0) >= 0)
{
-        LOG.info("Starting JobManger web frontend")
+        LOG.info("Starting JobManager web frontend")
         val leaderRetrievalService = LeaderRetrievalUtils
           .createLeaderRetrievalService(configuration)
 
@@ -2228,7 +2228,7 @@ object JobManager {
    *
    * @param configuration The configuration for the JobManager
    * @param actorSystem The actor system running the JobManager
-   * @param jobMangerActorName Optionally the name of the JobManager actor. If none is given,
+   * @param jobManagerActorName Optionally the name of the JobManager actor. If none is given,
    *                          the actor will have the name generated by the actor system.
    * @param archiveActorName Optionally the name of the archive actor. If none is given,
    *                          the actor will have the name generated by the actor system.
@@ -2239,7 +2239,7 @@ object JobManager {
   def startJobManagerActors(
       configuration: Configuration,
       actorSystem: ActorSystem,
-      jobMangerActorName: Option[String],
+      jobManagerActorName: Option[String],
       archiveActorName: Option[String],
       jobManagerClass: Class[_ <: JobManager],
       archiveClass: Class[_ <: MemoryArchivist])
@@ -2284,7 +2284,7 @@ object JobManager {
       savepointStore,
       jobRecoveryTimeout)
 
-    val jobManager: ActorRef = jobMangerActorName match {
+    val jobManager: ActorRef = jobManagerActorName match {
       case Some(actorName) => actorSystem.actorOf(jobManagerProps, actorName)
       case None => actorSystem.actorOf(jobManagerProps)
     }


Mime
View raw message