Stefan Richter created FLINK-4083:
-------------------------------------
Summary: 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)
