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

Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()".

    XMLWordPrintableJSON

    Details

      Description

      Because "subtaskFailed()" has no strong order guarantees with checkpoint completion, we need to return failed splits in "resetSubtask()" instead.

      See FLINK-20396 for a detailed explanation of the race condition.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sewen Stephan Ewen
                Reporter:
                sewen Stephan Ewen
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: