...
Deprecate following classes, fields and methods
RestartStrategy:
Class |
Annotation | |
org.apache.flink.api.common.restartstrategy.RestartStrategies | @PublicEvolving |
Method | Annotation |
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
#getRestartStrategy() | @Public |
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment#getRestartStrategy() |
org.apache.flink.api.common.ExecutionConfig |
#getRestartStrategy() |
@Public
org.apache.flink.api.common.ExecutionConfig#setRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration) |
Field |
Annotation |
org.apache.flink.api.common. |
Deprecate the entire class, includes its inner class
@PublicEvolving
ExecutionConfig#restartStrategyConfiguration | @Public |
Suggested alternative: Users can configure the RestartStrategyOptions related ConfigOptions, such as "restart-strategy.type", in the configuration, instead of passing a RestartStrategyConfiguration object.
CheckpointStorage
Class
Method | Annotation |
org.apache.flink.streaming.api.environment.CheckpointConfig |
#setCheckpointStorage(CheckpointStorage storage) | @Public |
org.apache.flink.streaming.api.environment.CheckpointConfig#setCheckpointStorage(String checkpointDirectory) | |
org.apache.flink.streaming.api.environment.CheckpointConfig#setCheckpointStorage(URI checkpointDirectory) | |
org.apache.flink.streaming.api.environment.CheckpointConfig#setCheckpointStorage(Path checkpointDirectory) | |
org.apache.flink.streaming.api.environment.CheckpointConfig#getCheckpointStorage() |
Suggested alternative: Users can configure "state.checkpoint-storage" in the configuration as the fully qualified name of the checkpoint storage or use some FLINK-provided checkpoint storage shortcut names such as "jobmanager" and "filesystem", and provide the necessary configuration options for building that storage, instead of passing a CheckpointStorage object.
StateBackend
Method |
Fields or Methods
Annotation |
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
#setStateBackend(StateBackend backend) | @Public |
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment#getStateBackend() |
Field | Annotation |
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment#defaultStateBackend | @Public |
Suggested alternative: Users can configure "state.backend.type" in the configuration as the fully qualified name of the state backend or use some FLINK-provided state backend shortcut names such as "hashmap" and "rocksdb", and provide the necessary configuration options for building that StateBackend, instead of passing a StateBackend object.
...