flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [2/9] flink git commit: [hotfix] Fix typos in Task and JobManager
Date Tue, 04 Jul 2017 17:10:20 GMT
[hotfix] Fix typos in Task and JobManager


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

Branch: refs/heads/master
Commit: 957cced552a60a9df21e76989f74d803eed6b924
Parents: 28c3354
Author: Nico Kruber <nico@data-artisans.com>
Authored: Wed Apr 19 15:39:03 2017 +0200
Committer: zentol <chesnay@apache.org>
Committed: Tue Jul 4 14:57:35 2017 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/runtime/taskmanager/Task.java   | 2 +-
 .../scala/org/apache/flink/runtime/jobmanager/JobManager.scala     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/957cced5/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
index 9dc6e34..65ce18c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
@@ -508,7 +508,7 @@ public class Task implements Runnable, TaskActions {
 	}
 
 	/**
-	 * The core work method that bootstraps the task and executes it code
+	 * The core work method that bootstraps the task and executes its code
 	 */
 	@Override
 	public void run() {

http://git-wip-us.apache.org/repos/asf/flink/blob/957cced5/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 100199b..9beae07 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
@@ -1792,7 +1792,7 @@ class JobManager(
       libraryCacheManager.unregisterJob(jobID)
     } catch {
       case t: Throwable =>
-        log.error(s"Could not properly unregister job $jobID form the library cache.", t)
+        log.error(s"Could not properly unregister job $jobID from the library cache.", t)
     }
     jobManagerMetricGroup.foreach(_.removeJob(jobID))
 


Mime
View raw message