[FLINK-22132] Test unaligned checkpoints rescaling manually on a real cluster

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.13.0
• Fix Version/s: 1.13.0
• Component/s: Runtime / Checkpointing
• Labels: release-testing test-stability
• Assignee: Anton Kalashnikov
• Reporter: Piotr Nowojski
• Created: 07/Apr/21 08:27
• Updated: 22/Jun/21 13:55
• Resolved: 27/Apr/21 13:49

Description

To test unaligned checkpoints, we should use a few different applications that use different features.

The sinks should not be mocked but rather should be able to induce a fair amount of backpressure into the system. Quite possibly, it would be a good idea to have a way to add more backpressure to the sink by running the respective system on the cluster and be able to add/remove parallel instances.

The primary objective is to check if all data is recovered properly and if the semantics is correct (does state match input?).

The secondary objective is to check if Flink UI shows the information correctly.

More details in the subtasks.

Sub-Tasks

• Device application for unaligned checkpoint test on cluster: Resolved
• Execute unaligned checkpoint test on a cluster: Closed