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

SlotSharingGroups are not always released in time for new restarts

    Details

      Description

      In the case where there are not enough resources to schedule the streaming program, a race condition can lead to a sequence of the following errors:

      java.lang.IllegalStateException: SlotSharingGroup cannot clear task assignment, group still has allocated resources.
      

      This eventually recovers, but may involve many fast restart attempts before doing so.

      The root cause is that slots are not cleared before the next restart attempt.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                StephanEwen Stephan Ewen
                Reporter:
                StephanEwen Stephan Ewen
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: