[FLINK-4078] Use ClosureCleaner for CoGroup where

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.3
• Fix Version/s: 1.1.0
• Assignee: Stefan Richter
• Reporter: Ufuk Celebi
• Created: 15/Jun/16 15:30
• Updated: 20/Jun/16 13:38
• Resolved: 20/Jun/16 13:38

Description

When specifying a key selector in the where clause of a CoGroup, the closure cleaner is not used.

.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();
                    }
                })

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().

Issue Links

• relates to: FLINK-4083 Use ClosureCleaner for Join where and equalTo
• links to: GitHub Pull Request #2116