Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4987#discussion_r156722826
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -757,6 +775,64 @@ public void heartbeatFromResourceManager(final
ResourceID resourceID) {
return
CompletableFuture.completedFuture(executionGraph.getState());
}
+
//----------------------------------------------------------------------------------------------
+ // RestfulGateway RPC methods
+
//----------------------------------------------------------------------------------------------
+
+ @Override
+ public CompletableFuture<String> requestRestAddress(Time timeout) {
+ return restAddressFuture;
+ }
+
+ @Override
+ public CompletableFuture<AccessExecutionGraph> requestJob(JobID jobId,
Time timeout) {
+ if (Objects.equals(jobGraph.getJobID(), jobId)) {
--- End diff --
True. Will refactor it.
---
