[flink] branch master updated: [hotfix][connector/source] fix comment typo

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gaoyunhaii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new e1ea80b  [hotfix][connector/source] fix comment typo
e1ea80b is described below

commit e1ea80bb09735ce5706f7e86840df8bc5f3ffcd2
Author: Jing Ge <ge...@gmail.com>
AuthorDate: Thu Dec 23 19:24:03 2021 +0100

    [hotfix][connector/source] fix comment typo
    
    This closes #18195.
---
 .../org/apache/flink/runtime/source/coordinator/SourceCoordinator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
index 85a767e..952ace4 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
@@ -116,7 +116,7 @@ public class SourceCoordinator<SplitT extends SourceSplit, EnumChkT>
         // 'start()' wasn't called and where 'start()' failed.
         started = true;
 
-        // there are two ways the coordinator can get created:
+        // there are two ways the SplitEnumerator can get created:
         //  (1) Source.restoreEnumerator(), in which case the 'resetToCheckpoint()' method creates
         // it
         //  (2) Source.createEnumerator, in which case it has not been created, yet, and we create