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

Make ResourceManager#internalDeregisterApplication and implementation asynchronous

    XMLWordPrintableJSON

Details

    Description

      Follow the discussion in this PR[1].

      Currently, ResourceManager#internalDeregisterApplication is a blocking call, so all the specific deployment implementation will do the Flink cluster deregister synchronously. 

      After FLINK-17024, we could get a safe thread pool to execute the I/O operations, including the "deregister". This ticket is to make the interface asynchronous. Benefit from this, the shutdown process will be a little faster. 

       

      [1]. https://github.com/apache/flink/pull/11427#issuecomment-613416114

      Attachments

        Issue Links

          is a child of

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-15788 Various Kubernetes integration improvements

          • Major - Major loss of function.
          • Closed
          is superceded by

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-23118 Drop Mesos support

          • Major - Major loss of function.
          • Closed

          Activity

            People

              Unassigned Unassigned
              wangyang0918 Yang Wang
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: