[jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()

[Shang Yuanchun (Jira)]

Ted Yu created FLINK-3325:
-----------------------------

             Summary: Unclosed InputStream in CEPPatternOperator#restoreState()
                 Key: FLINK-3325
                 URL: https://issues.apache.org/jira/browse/FLINK-3325
             Project: Flink
          Issue Type: Bug
            Reporter: Ted Yu
            Priority: Minor


Here is related code:
{code}
    final InputStream is = stream.getState(getUserCodeClassloader());
    final ObjectInputStream ois = new ObjectInputStream(is);
    final DataInputViewStreamWrapper div = new DataInputViewStreamWrapper(is);

    nfa = (NFA<IN>)ois.readObject();
{code}
Neither is nor ois is closed upon return from the method



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)