Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5938#discussion_r185080370
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -570,6 +571,21 @@ public LeaderConnectionInfo getClusterConnectionInfo()
throws LeaderRetrievalExc
});
}
+ @Override
+ public void shutDownCluster() {
+ try {
+ sendRetryableRequest(
+ ShutdownHeaders.getInstance(),
+ EmptyMessageParameters.getInstance(),
+ EmptyRequestBody.getInstance(),
+ isConnectionProblemException()).get();
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ } catch (ExecutionException e) {
+ log.error("Error while shutting down cluster", e);
--- End diff --
Throw the cause of the `ExecutionException`?
---
