dawidwys commented on a change in pull request #17135:
URL: https://github.com/apache/flink/pull/17135#discussion_r704130575
##########
File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md
##########
@@ -147,6 +154,11 @@ env.getCheckpointConfig.enableUnalignedCheckpoints()
// sets the checkpoint storage where checkpoint snapshots will be written
env.getCheckpointConfig.setCheckpointStorage("hdfs:///my/checkpoint/dir")
+
+// enable checkpointing with finished tasks
+val config = new Configuration()
+config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH,
true)
+env.configure(config)
Review comment:
I did add methods to the Python API in the past on multiple occasions.
Indeed, if it is just a setter, the issue is simple. Here, I'd really prefer
not to deal with it, as it deals with `Configuration`.
1. First of all I am not able to run the python tests. Configuring the IDE
to make them run, would take me quite some time.
2. In Java/Scala we use a type safe version of configuration
`ReadableConfig`. I don't know how we should solve that in python.
I can prepare a very naive PR, that could be a starter, but it would require
a lot of input from python maintainers anyway.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
