[jira] [Resolved] (FLINK-2916) Add more context information for the StateBackend

["Gyula Fora (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gyula Fora resolved FLINK-2916.
-------------------------------
    Resolution: Fixed

https://github.com/gyfora/flink/commit/ad6f826584be7527c58e2126e2828f82afc97875

> Add more context information for the StateBackend
> -------------------------------------------------
>
>                 Key: FLINK-2916
>                 URL: https://issues.apache.org/jira/browse/FLINK-2916
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Gyula Fora
>            Assignee: Gyula Fora
>            Priority: Minor
>
> The StateBackend currently only receives a very limited information about the context in which it was initialized (only the JobID). 
> For more elaborate state backends (for instance db backends) it becomes necessary to have more information about the running job to allow more fine-grained handling or sharding of the stored state. 
> Changes: 
>  - The initalizeForJob method should receive the Environment of the task from which it was called instead of just the jobId. This allows getting information about parallelism and subtask index for instance.
> - The createKvState method should additionally receive the unique id of the operator in the jobgraph along with the name of the created state name (jobid + operatorId + statename creates a unique identifier for the kvState)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)