This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
commit fa52d7d53c8852f12dba912089c759689fd92668
Author: Robert Metzger <rmetz...@apache.org>
AuthorDate: Mon Jun 21 22:19:49 2021 +0200
[hotfix] Fix some typos in comments
---
.../api/connector/source/lib/util/IteratorSourceEnumerator.java | 8 +++-----
.../flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java | 2 +-
.../flink/runtime/operators/coordination/OperatorCoordinator.java | 6 +++---
3 files changed, 7 insertions(+), 9 deletions(-)
diff --git
a/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java
b/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java
index 9c37cca..ff805c5 100644
---
a/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java
+++
b/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceEnumerator.java
@@ -78,10 +78,8 @@ public class IteratorSourceEnumerator<SplitT extends
IteratorSourceSplit<?, ?>>
@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/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
index c81a5dd..d9d392a 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
@@ -150,7 +150,7 @@ public class DefaultCheckpointPlanCalculator implements
CheckpointPlanCalculator
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/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
index 24a546c..2e2869f 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
@@ -30,7 +30,7 @@ import java.util.concurrent.CompletableFuture;
/**
* 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 @@ import java.util.concurrent.CompletableFuture;
* 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)
