[jira] [Updated] (FLINK-4078) Use ClosureCleaner for CoGroup where

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

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

Ufuk Celebi updated FLINK-4078:
-------------------------------
    Assignee: Stefan Richter

> Use ClosureCleaner for CoGroup where
> ------------------------------------
>
>                 Key: FLINK-4078
>                 URL: https://issues.apache.org/jira/browse/FLINK-4078
>             Project: Flink
>          Issue Type: Bug
>    Affects Versions: 1.0.3
>            Reporter: Ufuk Celebi
>            Assignee: Stefan Richter
>             Fix For: 1.1.0
>
>
> When specifying a key selector in the where clause of a CoGroup, the closure cleaner is not used.
> {code}
> .coGroup(filteredIds)
>                 .where(new KeySelector<T, String>() {
>                     @Override
>                     public String getKey(T t) throws Exception {
>                         String s = (String) t.get(fieldName);
>                         return s != null ? s : UUID.randomUUID().toString();
>                     }
>                 })
> {code}
> The problem is that the KeySelector is an anonymous inner class and as such as a reference to the outer object. Normally, this would be rectified by the closure cleaner but the cleaner is not used in CoGroup.where().



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