dianfu commented on a change in pull request #15441:
URL: https://github.com/apache/flink/pull/15441#discussion_r604996006
##########
File path: flink-python/pyflink/datastream/stream_execution_environment.py
##########
@@ -302,6 +302,31 @@ def set_state_backend(self, state_backend: StateBackend)
-> 'StreamExecutionEnvi
self._j_stream_execution_environment.setStateBackend(state_backend._j_state_backend)
return self
+ def set_default_savepoint_directory(self, 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.
+ """
+ return
self._j_stream_execution_environment.setDefaultSavepointDirectory(directory)
Review comment:
should return self
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
