You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/23 04:09:00 UTC
[jira] [Created] (FLINK-25423) Enable loading state backend via configuration in state processor api
Yun Tang created FLINK-25423:
--------------------------------
Summary: Enable loading state backend via configuration in state processor api
Key: FLINK-25423
URL: https://issues.apache.org/jira/browse/FLINK-25423
Project: Flink
Issue Type: Improvement
Components: API / State Processor, Runtime / State Backends
Reporter: Yun Tang
Fix For: 1.15.0
Currently, state processor API would load savepoint via explictly initalizated state backend on client side, which is like {{StreamExecutionEnvironment#setStateBackend(stateBackend)}}:
{code:java}
Savepoint.load(bEnv, "hdfs://path/", new HashMapStateBackend());
{code}
As we all konw, stream env also support to load state backend via configuration to provide flexibility to load state backends especially some customized state backend. This could also benefit state processor API with similiar ability.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)