[jira] [Created] (FLINK-8351) Canonical way to extract FoldingState QueryableStateStream

["Raymond Tay (JIRA)" <ji...@apache.org>]

Raymond Tay created FLINK-8351:
----------------------------------

             Summary: Canonical way to extract FoldingState QueryableStateStream
                 Key: FLINK-8351
                 URL: https://issues.apache.org/jira/browse/FLINK-8351
             Project: Flink
          Issue Type: Bug
          Components: Queryable State
    Affects Versions: 1.4.0
         Environment: h3. Environment
* Local flink cluster version 1.4.0
* {{classloader.resolve-order: child-first}} in {{conf/flink-conf.yaml}}.
* scala 2.11.11
* oracle jdk 1.8.0

h3. Library version
* akka actors 2.4.20
* akka http 10.0.10
            Reporter: Raymond Tay


I started experimenting with {{QueryableStateStream}} by referencing this site which is linked by Flink's website ⇒ https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/queryable_state.html 

I think the example given is perfectly fine and runs w/o much issue. However, i started extrapolating the situation to have a {{FoldingState}} where the application continuously updates the state and another part of the application retrieves the state and i ran into the following situation:

* Is there a canonical way or API that allows the app to extract the submitted job-id in order to query the current state 
** As a work around, i'm querying the url {{localhost:8081/jobs}} but this does not work when there are other jobs running
* Is there another way to query the state other than {{polling}} ? Is it possible to to return the final result as part of the {{JobExecutionResult}}
** At the moment, the app is polling the url {{localhost:8081/jobs}} and using that {{JobID}} to query the state but when the job completes, the job's state is not persisted and i lose the _final_ state value

I realized {{QueryableStateStream}} is in {{beta}} as of the time of this issue so there are things i might have missed. Any help or tip is greatly appreciated ☺



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)