Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23474

InputStatus should not contain END_OF_RECOVERY

    XMLWordPrintableJSON

    Details

    • 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.

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dwysakowicz Dawid Wysakowicz
                Reporter:
                dwysakowicz Dawid Wysakowicz
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: