pyflink.datastream.checkpoint_config.CheckpointConfig.get_checkpoint_storage#
- CheckpointConfig.get_checkpoint_storage() Optional[pyflink.datastream.checkpoint_storage.CheckpointStorage] [source]#
The checkpoint storage that has been configured for the Job, or None if none has been set.
Note
Deprecated since version 1.19: This method is deprecated and will be removed in future FLINK major version. It is recommended to find which checkpoint storage is used by checkpoint storage ConfigOption.