StephanEwen commented on a change in pull request #15601:
URL: https://github.com/apache/flink/pull/15601#discussion_r613005989
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
##########
@@ -226,6 +219,26 @@ default void notifyCheckpointAborted(long checkpointId) {}
// ------------------------------------------------------------------------
+ interface SubtaskGateway {
+
+ /**
+ * Sends an event to the parallel subtask with the given subtask index.
+ *
+ * <p>The returned future is completed successfully once the event has
been received by the
+ * target TaskManager. The future is completed exceptionally if the
event cannot be sent.
+ * That includes situations where the target task is not running.
+ */
+ CompletableFuture<Acknowledge> sendEvent(OperatorEvent evt);
+
+ ExecutionAttemptID getExecution();
+
+ int getSubtask();
+
+ boolean isReady();
Review comment:
That is right, we can drop this. It is leftover from an earlier version.
Will remove this.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
