[Hotfix] fix typos

mbalassi · Jun 13, 2022 · d389a47 · d389a47
1 parent 4e2f41f
commit d389a47
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/api/connector/source/Source.java b/flink-core/src/main/java/org/apache/flink/api/connector/source/Source.java
@@ -57,7 +57,7 @@ public interface Source<T, SplitT extends SourceSplit, EnumChkT> extends Seriali
  *
  * @param enumContext The {@link SplitEnumeratorContext context} for the split enumerator.
  * @return A new SplitEnumerator.
- * @throws Exception The implementor is free to forward all exceptions directly. * Exceptions
+ * @throws Exception The implementor is free to forward all exceptions directly. Exceptions
  * thrown from this method cause JobManager failure/recovery.
  */
  SplitEnumerator<SplitT, EnumChkT> createEnumerator(SplitEnumeratorContext<SplitT> enumContext)
@@ -70,7 +70,7 @@ SplitEnumerator<SplitT, EnumChkT> createEnumerator(SplitEnumeratorContext<SplitT
  * enumerator.
  * @param checkpoint The checkpoint to restore the SplitEnumerator from.
  * @return A SplitEnumerator restored from the given checkpoint.
- * @throws Exception The implementor is free to forward all exceptions directly. * Exceptions
+ * @throws Exception The implementor is free to forward all exceptions directly. Exceptions
  * thrown from this method cause JobManager failure/recovery.
  */
  SplitEnumerator<SplitT, EnumChkT> restoreEnumerator(
@@ -90,7 +90,7 @@ SplitEnumerator<SplitT, EnumChkT> restoreEnumerator(
 
  /**
  * Creates the serializer for the {@link SplitEnumerator} checkpoint. The serializer is used for
- * the result of the {@link SplitEnumerator#snapshotState()} method.
+ * the result of the {@link SplitEnumerator#snapshotState} method.
  *
  * @return The serializer for the SplitEnumerator checkpoint.
  */