dmvk commented on a change in pull request #16881:
URL: https://github.com/apache/flink/pull/16881#discussion_r692025435
##########
File path:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
##########
@@ -371,14 +370,24 @@ public void close() {
});
final CompletableFuture<JobSubmitResponseBody> submissionFuture =
- requestFuture.thenCompose(
- requestAndFileUploads ->
- sendRetriableRequest(
- JobSubmitHeaders.getInstance(),
- EmptyMessageParameters.getInstance(),
- requestAndFileUploads.f0,
- requestAndFileUploads.f1,
-
isConnectionProblemOrServiceUnavailable()));
+ requestFuture
+ .thenCompose(
+ requestAndFileUploads ->
+ sendRetriableRequest(
+ JobSubmitHeaders.getInstance(),
+
EmptyMessageParameters.getInstance(),
+ requestAndFileUploads.f0,
+ requestAndFileUploads.f1,
+
isConnectionProblemOrServiceUnavailable()))
+ .thenApply(
+ response -> {
Review comment:
For a) we only log job name and job id. For b) we now log both
successful and failed request alongside the receiving dispatcher.
--
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]
