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/
