Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5750#discussion_r177353937
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java
---
@@ -92,7 +96,29 @@ public static void main(String[] args) throws Exception {
// create the environment to create streams and configure
execution
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
- env.enableCheckpointing(5000);
+
+ final String checkpointDir =
params.getRequired("checkpointDir");
--- End diff --
We could do this also via the `flink-conf.yaml` and don't make the
parameters of the example too complicated.
---
