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

Eagerly close checkpoint streams on cancellation

    XMLWordPrintableJSON

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

              sewen Stephan Ewen
              sewen Stephan Ewen
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: