[FLINK-9192] Undo parameterization of StateMachine Example

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Examples
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Stephan Ewen
• Created: 17/Apr/18 13:25
• Updated: 08/Dec/21 22:38

Description

The example has been changed to add parametrization and a different sink.

I would vote to undo these changes, the make the example less nice and use non-recommended sinks:

• For state backend, incremental checkpoints, async checkpoints, etc. having these settings in the example blows up the parameter list of the example and distracts from what the example is about.
• If the main reason for this is an end-to-end test, then these settings should go into the test's Flink config.
• The writeAsText is a sink that is not recommended to use, because it is not integrated with checkpoints and has no well defined semantics.

Issue Links

• Blocked: FLINK-9320 Update `test-ha.sh` end-to-end test to use general purpose DataStream job