Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r154950988
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -191,9 +196,12 @@ public String getClientName() {
CompletableFuture.allOf(
connectionFutures.toArray(new
CompletableFuture<?>[connectionFutures.size()])
).whenComplete((result, throwable) -> {
+
if (throwable != null) {
-
newShutdownFuture.completeExceptionally(throwable);
- } else if (bootstrap != null) {
+ LOG.warn("Problem while shutting down
the connections at the {}: {}", clientName, throwable);
--- End diff --
`LOG.warn("Problem while shutting down the connections at the {}",
clientName, throwable);` instead?
---
