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

When using session windows, the state of slot 1 keeps growing

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Invalid
    • 1.14.4
    • None
    • API / DataStream
    • None

    Description

      This will happen no matter how much parallelism  I set, and it will always be in slot id 1.

      I have set different parallelism (50/100/120/140).

      The amount of data received is about the same as other slots, but the state is much larger and growing.

      The same code is running normally in the test environment (parallelism is 10).

       

      Thank you for your help~

      Attachments

        1. Window Function Received Details.png
          23 kB
          linweijiang
        2. Checkpoint Details.png
          53 kB
          linweijiang

        Activity

          People

            Unassigned Unassigned
            leen linweijiang
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: