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)