[hotfix] [doc] Fix typo in TaskManager and EnvironmentInformation doc

This closes apache#5135.
InfinitiesLoop · Dec 18, 2017 · 7f99a0d · 7f99a0d
1 parent c57e56f
commit 7f99a0d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java
@@ -259,7 +259,7 @@ public static long getOpenFileHandlesLimit() {
  }
 
  /**
- * Logs a information about the environment, like code revision, current user, java version,
+ * Logs information about the environment, like code revision, current user, Java version,
  * and JVM parameters.
  *
  * @param log The logger to log the information to.

diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
@@ -585,8 +585,8 @@ class TaskManager(
  config.getMaxRegistrationPause().toMilliseconds,
  TimeUnit.MILLISECONDS))
 
- // schedule (with our timeout s delay) a check triggers a new registration
- // attempt, if we are not registered by then
+ // schedule a check to trigger a new registration attempt if not registered
+ // by the timeout
  scheduledTaskManagerRegistration = Option(context.system.scheduler.scheduleOnce(
  timeout,
  self,
@@ -1898,7 +1898,7 @@ object TaskManager {
  }
 
  /**
- * Starts and runs the TaskManager. with all its components trying to bind to
+ * Starts and runs the TaskManager with all its components trying to bind to
  * a port in the specified range.
  *
  * @param taskManagerHostname The hostname/address of the interface where the actor system