Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5750#discussion_r177354347
--- 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 --
In any case you should update the `usage string` above and end to end tests
that depend on this test as well.
---
