pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_default_savepoint_directory

StreamExecutionEnvironment.set_default_savepoint_directory(directory: str) → StreamExecutionEnvironment

Sets the default savepoint directory, where savepoints will be written to if none is explicitly provided when triggered.

Example:

>>> env.set_default_savepoint_directory("hdfs://savepoints")

:param directory The savepoint directory :return: This object.