Hello,

I would like to enable fs backend for the state of my job.
Following the guides:

-
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/state_backends.html#setting-the-per-job-state-backend

-
https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/state_backends.html#the-fsstatebackend

what I need to do is:

StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();env.setStateBackend(new
FsStateBackend("hdfs://namenode:40010/flink/checkpoints"));

However, when I do this, I get a deprecation warning which says "@deprecated
Use {@link #setStateBackend(StateBackend)} instead.":
https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.html#setStateBackend-org.apache.flink.runtime.state.AbstractStateBackend
<https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.html#setStateBackend-org.apache.flink.runtime.state.AbstractStateBackend->

Which class should I use instead of this one so I do not get a warning? Is
it possible to reflect that in the docs?

Thank you

Regards
,
Nikola Hrusov

Reply via email to