Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12069 Add proper lifecycle management for intermediate result partitions
  3. FLINK-12842

Fix invalid check released state during ResultPartition#createSubpartitionView

    XMLWordPrintableJSON

    Details

      Description

      Currently in ResultPartition#createSubpartitionView it would check whether this partition is released before creating view. But this check is based on refCnt != -1 which seems invalid, because the reference counter would not always reflect the released state.

      In the case of ResultPartition#release/fail, the reference counter is not set to -1. Even if in the case of ResultPartition#onConsumedSubpartition, the reference counter seems also no chance to be -1.

      So we could check the real isReleased state during creating view instead of reference counter.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                zjwang Zhijiang
                Reporter:
                zjwang Zhijiang
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m