[FLINK-17517] Add failure recovery / exactly-once E2E for Stateful Functions

• Type: Sub-task
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: statefun-2.0.1, statefun-2.1.0
• Component/s: Stateful Functions
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 05/May/20 08:32
• Updated: 15/May/20 11:15
• Resolved: 15/May/20 11:15

Description

Implementation should be based on top of the StatefulFunctionsAppContainers test containers utility.

The verification should write some records to a Stateful Functions app (via a Kafka ingress), simulate failure by restarting containers, and assert that the result is not corrupt.