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

Hybrid Shuffle may face deadlock when running a task need to execute big size data

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.16.0
    • 1.17.0, 1.16.1
    • Runtime / Network
    • None

    Description

      The flink 1.16 offers hybrid shuffle to combine the superiority of blocking shuffle and pipeline shuffle. But when I want to test this new feature I face a problem that it may cause deadlock when it running. 

      Actually, it will run well at beginning. However, when it runs to a certain number it may failure for the buffer size and if I set a bigger size it may running without data execution like the picture. So I want to ask the cause of this problem and a solution.

      Attachments

        1. 性能差距.png
          418 kB
          AlexHu
        2. 死锁2-select.png
          382 kB
          AlexHu
        3. 死锁检测.png
          207 kB
          AlexHu

        Issue Links

          Activity

            People

              Unassigned Unassigned
              AlexXXX AlexHu
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: