zentol commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1144748299
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerNG.java:
##########
@@ -185,4 +187,28 @@ void deliverOperatorEventToCoordinator(
*/
CompletableFuture<CoordinationResponse>
deliverCoordinationRequestToCoordinator(
OperatorID operator, CoordinationRequest request) throws
FlinkException;
+
+ /**
+ * Read current {@link JobResourceRequirements job resource requirements}.
+ *
+ * @return Current resource requirements.
+ */
+ default JobResourceRequirements requestJobResourceRequirements() {
+ throw new UnsupportedOperationException(
Review Comment:
Will try to keep this in mind for the PR that adds the rest api handlers.
--
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]
