[FLINK-9019] Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Assignee: vinoyang
• Reporter: Ted Yu
• Created: 19/Mar/18 01:27
• Updated: 20/Mar/18 16:42
• Resolved: 20/Mar/18 16:42

Description

     final CloseableRegistry closeableRegistry = new CloseableRegistry();
...
     if (rawOperatorState != null) {
...
      }
    }

    return CloseableIterable.empty();

If rawOperatorState is null, closeableRegistry would be left unclosed.

Issue Links

• links to: GitHub Pull Request #5723