Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6069#discussion_r190605670
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -314,7 +319,8 @@ public JobSubmissionResult submitJob(JobGraph jobGraph,
ClassLoader classLoader)
log.info("Requesting blob server port.");
CompletableFuture<BlobServerPortResponseBody> portFuture =
sendRequest(
- BlobServerPortHeaders.getInstance());
+ BlobServerPortHeaders.getInstance(),
+ EmptyMessageParameters.getInstance());
--- End diff --
This is not needed. There should be an overload of `sendRequest` that does
it.
---
