[FLINK-2191] Inconsistent use of Closure Cleaner in Streaming API

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.9
• Fix Version/s: 0.9
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 09/Jun/15 13:39
• Updated: 28/Feb/19 11:15
• Resolved: 10/Jun/15 15:25

Description

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.