[ https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ufuk Celebi closed FLINK-4078. ------------------------------ Resolution: Fixed Fixed in 78d3c61 (master). > 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)