flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ted Yu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()
Date Wed, 03 Feb 2016 14:42:40 GMT
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)

Mime
View raw message