[FLINK-20079] Modified UnalignedCheckpointITCase...MassivelyParallel fails

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.3
• Fix Version/s: 1.12.0, 1.11.3
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 10/Nov/20 20:07
• Updated: 12/Nov/20 08:57
• Resolved: 11/Nov/20 16:50

Description

In FLINK-19681, UnalignedCheckpointITCase was updated to put more backpressure.

This revealed a bug introduced in FLINK-19907: resultPartitions can be requested before the operator chain is initialized.

A proper fix would be to initialize the chain after the outputs but before the inputs.

Issue Links

• is related to: FLINK-20103 Improve test coverage for network stack
• links to: GitHub Pull Request #14024
• links to: GitHub Pull Request #14025