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

Resource leak would happen if exception thrown during AbstractInvokable#restore of task life

    XMLWordPrintableJSON

    Details

      Description

      FLINK-17012 introduced new initialization phase such as AbstractInvokable.restore, however, if invokable.restore() throws exception out, no more StreamTask#cleanUpInvoke would be called, leading to resource leak.

      We internally leveraged another way to use managed memory by registering specific operator identifier in memory manager, forgetting to call the stream task cleanup would let stream operator not be disposed and we have to face critical resource leak.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                akalashnikov Anton Kalashnikov
                Reporter:
                yunta Yun Tang
              • Votes:
                0 Vote for this issue
                Watchers:
                11 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: