rkhachatryan commented on code in PR #22296:
URL: https://github.com/apache/flink/pull/22296#discussion_r1152994060
##########
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherGateway.java:
##########
@@ -108,4 +109,26 @@ default CompletableFuture<String>
stopWithSavepointAndGetLocation(
@RpcTimeout final Time timeout) {
throw new UnsupportedOperationException();
}
+
+ /**
+ * Read current {@link JobResourceRequirements job resource requirements}
for a given job.
+ *
+ * @param jobId job to read the resource requirements for
+ * @return Future which that contains current resource requirements.
+ */
+ default CompletableFuture<JobResourceRequirements>
requestJobResourceRequirements(JobID jobId) {
Review Comment:
In the parent `RestfulGateway` class, most methods are called `requestXxx`
(although not all).
So I guess it would be more consistent to start this one with `request` too.
--
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]
