Aljoscha Krettek created FLINK-2191:
---------------------------------------

             Summary: Inconsistent use of Closure Cleaner in Streaming API
                 Key: FLINK-2191
                 URL: https://issues.apache.org/jira/browse/FLINK-2191
             Project: Flink
          Issue Type: Bug
          Components: Streaming
    Affects Versions: 0.9
            Reporter: Aljoscha Krettek
            Priority: Blocker


In the streaming API operations on DataStream.java call clean() if the closure 
cleaner is enabled in the execution config. Methods in 
StreamExecutionEnvironment.java always call clean, no way of disabling it. 
Operations in the Scala Streaming API also always call clean(), no way of 
disabling it.



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

Reply via email to