[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253782#comment-16253782
]
ASF GitHub Bot commented on FLINK-8063:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151184079
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
@@ -917,20 +1023,24 @@ public void processElement(Tuple2<Integer, Long>
value, Context ctx, Collector<O
cluster.submitJobDetached(jobGraph);
+ // wait until the job is running before starting to
query.
+
FutureUtils.toJava(cluster.getLeaderGateway(deadline.timeLeft())
--- End diff --
we could move this into a utility method
> Client blocks indefinitely when querying a non-existing state
> -------------------------------------------------------------
>
> Key: FLINK-8063
> URL: https://issues.apache.org/jira/browse/FLINK-8063
> Project: Flink
> Issue Type: Improvement
> Components: Queryable State
> Affects Versions: 1.4.0
> Reporter: Chesnay Schepler
> Assignee: Kostas Kloudas
> Priority: Critical
> Fix For: 1.4.0
>
>
> When querying for a non-existing state (as in, no state was registered under
> queryableStateName) the client blocks indefinitely.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
