Hmm.
If you have a wrapper function like this, it will not report deprecated
warning.
*def getFsStateBackend(path: String): StateBackend = return new
FsStateBackend(path) *
Since AbstractStateBackend implements StateBackend and
*def setStateBackend(backend: StateBackend): StreamExecutionEnvironment* is
not deprecated.
This seems like a bug to me though.
--
Rong
On Tue, Jun 26, 2018 at 7:40 PM zhangminglei <18717838...@163.com> wrote:
> At the moment, it seems you can not. Because FsStateBackend extends
> AbstructFileStateBackend then extend AbstructStateBackend which is
> deprecated in *setStateBackend* parameter.. I think you can do what you
> want like below now but it is very bad.
>
> env.setStateBackend(new StateBackend() {
> @Override
> public CompletedCheckpointStorageLocation resolveCheckpoint(String
> externalPointer) throws IOException {
> return null;
> }
>
> @Override
> public CheckpointStorage createCheckpointStorage(JobID jobId) throws
> IOException {
> return null;
> }
>
> @Override
> public <K> AbstractKeyedStateBackend<K> createKeyedStateBackend(Environment
> env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer,
> int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry
> kvStateRegistry) throws Exception {
> return null;
> }
>
> @Override
> public OperatorStateBackend createOperatorStateBackend(Environment env,
> String operatorIdentifier) throws Exception {
> return null;
> }
> });
>
> Cheers
> Minglei
>
>
> 在 2018年6月27日，上午9:38，chrisr123 <chris.rueg...@gmail.com> 写道：
>
>
> I upgraded from Flink 1.4 to 1.5 and now this call is being flagged as
> deprecated.
> What should I change this code to for 1.5 to get rid of the deprecation
> warning?
> Thanks
>
> // deprecated
> env.setStateBackend(new
> FsStateBackend("hdfs://myhdfsmachine:9000/flink/checkpoints"));
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
>
>
