Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25027 Allow GC of a finished job's JobMaster before the slot timeout is reached
  3. FLINK-25086

Move resource timeout checkers in JM from akka executors to the dedicated thread pool

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.14.0, 1.12.5, 1.13.3
    • None
    • Runtime / Coordination
    • None

    Description

      Move the resource timeout checkers from akka executors to the dedicated thread pool in jm, and these checkers will be removed when the job termitates. The timeout checker includes PhysicalSlotRequestBulkCheckerImpl, timeout checker of `pending request`/`checkIdleSlotTimeout`/`checkBatchSlotTimeout` in DeclarativeSlotPoolBridge and some other resource timeout checkers.

      Attachments

        Activity

          People

            Unassigned Unassigned
            zjureel Shammon
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: