[jira] [Issue Comment Deleted] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

["Stefan Richter (JIRA)" <ji...@apache.org>]

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

Stefan Richter updated FLINK-4083:
----------------------------------
    Comment: was deleted

(was: Same problem.)

> Use ClosureCleaner for Join where and equalTo
> ---------------------------------------------
>
>                 Key: FLINK-4083
>                 URL: https://issues.apache.org/jira/browse/FLINK-4083
>             Project: Flink
>          Issue Type: Bug
>    Affects Versions: 1.0.3
>            Reporter: Stefan Richter
>            Assignee: Stefan Richter
>            Priority: Minor
>
> When specifying a key selector in the where or equalTo clause of a Join, the closure cleaner is not used. Same problem as FLINK-4078.
> {code}
> .join(ds)
> 	.where(new KeySelector<CustomType, Integer>() {
> 		@Override
> 		public Integer getKey(CustomType value) {
> 			return value.myInt;
> 		}
> 	})
> 	.equalTo(new KeySelector<CustomType, Integer>(){
> 		@Override
> 		public Integer getKey(CustomType value) throws Exception {
> 			return value.myInt;
> 		}
> 	});
> {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)