[hotfix] Fix some typos in comments

pppsunil · Jun 25, 2021 · 7475027 · 7475027
1 parent 88152c0
commit 7475027
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 9 deletions.
diff --git a/...rc/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java b/...rc/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java
@@ -78,10 +78,8 @@ public Collection<SplitT> snapshotState(long checkpointId) throws Exception {
 
     @Override
     public void addReader(int subtaskId) {
-        // we don't assign any splits here, because this registration happens after fist startup
-        // and after each reader restart/recovery
-        // we only want to assign splits once, initially, which we get by reacting to the readers
-        // explicit
-        // split request
+        // we don't assign any splits here, because this registration happens after fist startup and
+        // after each reader restart/recovery we only want to assign splits once, initially, which
+        // we get by reacting to the readers explicit split request
     }
 }
diff --git a/...me/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java b/...me/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
@@ -150,7 +150,7 @@ private void checkTasksStarted(List<Execution> toTrigger) throws CheckpointExcep
             if (execution.getState() != ExecutionState.RUNNING) {
                 throw new CheckpointException(
                         String.format(
-                                "Checkpoint triggering task %s of job %s has not being executed at the moment. "
+                                "Checkpoint triggering task %s of job %s is not being executed at the moment. "
                                         + "Aborting checkpoint.",
                                 execution.getVertex().getTaskNameWithSubtaskIndex(), jobId),
                         CheckpointFailureReason.NOT_ALL_REQUIRED_TASKS_RUNNING);

diff --git a/...me/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java b/...me/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
@@ -30,7 +30,7 @@
 
 /**
  * A coordinator for runtime operators. The OperatorCoordinator runs on the master, associated with
- * the job vertex of the operator. It communicated with operators via sending operator events.
+ * the job vertex of the operator. It communicates with operators via sending operator events.
  *
  * <p>Operator coordinators are for example source and sink coordinators that discover and assign
  * work, or aggregate and commit metadata.
@@ -62,7 +62,7 @@
  *       scheduler determined which checkpoint to restore, these methods notify the coordinator of
  *       that. The former method is called in case of a regional failure/recovery (affecting
  *       possible a subset of subtasks), the later method in case of a global failure/recovery. This
- *       method should be used to determine which actions to recover, because it tells you with
+ *       method should be used to determine which actions to recover, because it tells you which
  *       checkpoint to fall back to. The coordinator implementation needs to recover the
  *       interactions with the relevant tasks since the checkpoint that is restored.
  *   <li>{@link #subtaskReady(int, SubtaskGateway)}: Called again, once the recovered tasks are
@@ -133,7 +133,7 @@ public interface OperatorCoordinator extends CheckpointListener, AutoCloseable {
      *       checkpoint.
      * </ul>
      *
-     * @throws Exception Any exception thrown by this method results in a full job failure and *
+     * @throws Exception Any exception thrown by this method results in a full job failure and
      *     recovery.
      */
     void checkpointCoordinator(long checkpointId, CompletableFuture<byte[]> resultFuture)