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

A result partition is not untracked after its producer task failed in TaskManager

    XMLWordPrintableJSON

Details

    Description

      Execution#maybeReleasePartitionsAndSendCancelRpcCall(...) will be not invoked when a task is reported to be failed in TaskManager, which results in its partitions to still be tacked by the job manager partition tracker.

      Attachments

        Issue Links

          Activity

            People

              zhuzh Zhu Zhu
              zhuzh Zhu Zhu
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: