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

TaskManager hung in cleanupAllocationBaseDirs not exit.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.11.0
    • None
    • Runtime / Coordination
    • None

    Description

      The disk TaskManager used had some fatal error. And then TaskManager hung in cleanupAllocationBaseDirs and took the main thread.
       
      So this TaskManager would not respond to the cancelTask/disconnectResourceManager request.
       
      At the same time, JobMaster already take this TaskManager is lost, and schedule task to other TaskManager.
       
      This may cause some unexpected task running.
       
      After checking the log of TaskManager, TM already lost the connection with ResourceManager, and it is always trying to register with ResourceManager. The RegistrationTimeout cannot take effect because the main thread of TaskManager is hung-up.
       
      I think there are two options to handle it.

      Option 1: Add timeout for TaskExecutorLocalStateStoreManager.cleanupAllocationBaseDirs, But I am afraid some other methods would block main thread too.
      Option 2: Move the registrationTimeout in another thread, we need to deal will the concurrency problem

       
       

      Attachments

        1. origin_img_v2_bb063beb-2f44-40fe-b1d2-4cc8dc87585g.png
          486 kB
          huweihua
        2. 1280X1280.png
          97 kB
          huweihua

        Activity

          People

            Unassigned Unassigned
            huwh huweihua
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: