chucheng92 commented on code in PR #21464:
URL: https://github.com/apache/flink/pull/21464#discussion_r1056014959


##########
flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumeratorContext.java:
##########
@@ -126,6 +126,16 @@ default void assignSplit(SplitT split, int subtask) {
      */
     void signalNoMoreSplits(int subtask);
 
+    /**
+     * Signals a subtask that it will not receive split for current source, 
but it will receive
+     * split for next sources. A common scenario is HybridSource. This 
indicates that task not truly
+     * read finished.
+     *
+     * @param subtask The index of the operator's parallel subtask that shall 
be signaled it will
+     *     receive splits later.
+     */
+    default void signalIntermediateNoMoreSplits(int subtask) {}

Review Comment:
   @zhuzhurk Yes. SplitEnumeratorContext is a Public api. i add it with default 
method to avoid impact. We can not use `realContext instanceOf 
SourceCoordinatorContext` directly, HybridSourceSplitEnumerator is in 
flink-connector-base, SourceCoordinatorContext in is flink-runtime, how can we 
reference it?  using class FQDN or add runtime dependency both are ugly.  Is 
there a more elegant way ?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to