Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151182879
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
@@ -133,12 +131,11 @@ private void executeActionAsync(
operationFuture.whenCompleteAsync(
(t, throwable) -> {
if (throwable != null) {
- if (throwable
instanceof CancellationException) {
-
result.completeExceptionally(throwable);
- } else if
(throwable.getCause() instanceof UnknownKvStateIdException ||
+ if (
+
throwable.getCause() instanceof UnknownKvStateIdException ||
--- End diff --
Then, in which cases is an UnknownKvStateIdException thrown? That actually
sounds more appropriate.
---
