THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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() | |
org.apache.flink.api.common. |
ExecutionConfig#setRestartStrategy(RestartStrategies. |
RestartStrategyConfiguration restartStrategyConfiguration) |
Field | Annotation |
org.apache.flink.api.common.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
| 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 | 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.
...