[FLINK-8065][QS] Improve error message when client already shut down.

laubersder · Nov 17, 2017 · 75c1454 · 75c1454
1 parent ff7e3cf
commit 75c1454
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...yable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java b/...yable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
@@ -133,7 +133,7 @@ public String getClientName() {
 
  public CompletableFuture<RESP> sendRequest(final InetSocketAddress serverAddress, final REQ request) {
  if (shutDown.get()) {
- return FutureUtils.getFailedFuture(new IllegalStateException("Shut down"));
+ return FutureUtils.getFailedFuture(new IllegalStateException(clientName + " is already shut down."));
  }
 
  EstablishedConnection connection = establishedConnections.get(serverAddress);