You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2018/05/29 16:43:18 UTC
flink git commit: [FLINK-9356][qs] Improve error message when QS not
ready / reachable
Repository: flink
Updated Branches:
refs/heads/master 44c24c1bb -> 0fd497a7b
[FLINK-9356][qs] Improve error message when QS not ready / reachable
This closes #6028.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0fd497a7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0fd497a7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0fd497a7
Branch: refs/heads/master
Commit: 0fd497a7bf00694302a71ccf4b3ddd214942a228
Parents: 44c24c1
Author: yanghua <ya...@gmail.com>
Authored: Thu May 17 09:18:24 2018 +0200
Committer: kkloudas <kk...@gmail.com>
Committed: Tue May 29 18:42:45 2018 +0200
----------------------------------------------------------------------
.../queryablestate/client/proxy/KvStateClientProxyHandler.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0fd497a7/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
----------------------------------------------------------------------
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java b/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
index 8201305..1586566 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
@@ -225,7 +225,10 @@ public class KvStateClientProxyHandler extends AbstractServerHandler<KvStateRequ
return location;
} else {
- return FutureUtils.completedExceptionally(new UnknownLocationException("Could not contact the state location oracle to retrieve the state location."));
+ return FutureUtils.completedExceptionally(
+ new UnknownLocationException(
+ "Could not retrieve location of state=" + queryableStateName + " of job=" + jobId +
+ ". Potential reasons are: i) the state is not ready, or ii) the job does not exist."));
}
}