[FLINK-23474] InputStatus should not contain END_OF_RECOVERY

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.1
• Fix Version/s: 1.14.0
• Component/s: API / DataStream, Runtime / Task
• Labels: pull-request-available
• Release Note: InputStatus.END_OF_RECOVERY was removed. It was an internal flag that should never be returned from SourceReaders. Returning that value in earlier versions might lead to misbehaviour.
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 22/Jul/21 12:31
• Updated: 28/Aug/21 12:22
• Resolved: 26/Jul/21 10:59

Description

We added the END_OF_RECOVERY enum value in order to support recovery of unaligned checkpoints with rescaling.

However the InputStatus is expose in a public interface via SourceReader. At the same time it is not a valid value which the SourceReader can return.

We should internally replace the InputStatus with an internal equivalent.

Issue Links

• is caused by: FLINK-19801 Add support for virtual channels
• links to: GitHub Pull Request #16581