zhuzhurk commented on code in PR #21785:
URL: https://github.com/apache/flink/pull/21785#discussion_r1090489821
##########
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java:
##########
@@ -579,6 +579,28 @@ public interface InitializeOnMasterContext {
int getExecutionParallelism();
}
+ /** The context exposes some runtime infos for finalization. */
+ public interface FinalizationOnMasterContext {
Review Comment:
FinalizationOnMasterContext -> FinalizeOnMasterContext
To be aligned with `InitializeOnMasterContext`.
##########
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java:
##########
@@ -579,6 +579,28 @@ public interface InitializeOnMasterContext {
int getExecutionParallelism();
}
+ /** The context exposes some runtime infos for finalization. */
+ public interface FinalizationOnMasterContext {
+ /** The class loader for user defined code. */
+ ClassLoader getClassLoader();
+
+ /**
+ * The actual parallelism this vertex will be run with. In contrast,
the {@link
+ * #getParallelism()} is the original parallelism set when creating
the {@link JobGraph} and
+ * might be updated e.g. by the {@link
+ * org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler}.
+ */
+ int getExecutionParallelism();
+
+ /**
+ * Get the finished attempt number of subtask.
+ *
+ * @param subtaskIndex the subtask index.
+ * @return the finished attempts.
Review Comment:
attempts -> attempt
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
