Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150890435
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -208,9 +239,15 @@ public void shutdown() {
/** The established connection after the connect succeeds. */
private EstablishedConnection established;
+ /** Atomic shut down future. */
+ private final AtomicReference<CompletableFuture<?>>
connectionShutdownFuture = new AtomicReference<>(null);
+
/** Closed flag. */
private boolean closed;
+// /** Shut down future. */
--- End diff --
?
---
