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

Eagerly close checkpoint streams on cancellation

    Details

      Description

      Some output streams perform blocking operations that cannot be properly interrupted. This causes cancellations to take very long when happening concurrently to large synchronous state snapshot operations.

      Closing the streams concurrently helps to abort these blocking operations.

      This might already be fixed in 1.2 by the CloseableRegistry.

        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: