You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/10 17:26:00 UTC

[jira] [Closed] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

     [ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Márton Balassi closed FLINK-2191.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 0.9

Implemented via e2304c4. Minor issue remains, tracked in FLINK-2201.

> 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
>            Assignee: Aljoscha Krettek
>            Priority: Blocker
>             Fix For: 0.9
>
>
> 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)