flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stefan Richter (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo
Date Thu, 16 Jun 2016 13:18:05 GMT
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.

	.where(new KeySelector<CustomType, Integer>() {
		public Integer getKey(CustomType value) {
			return value.myInt;
	.equalTo(new KeySelector<CustomType, Integer>(){

		public Integer getKey(CustomType value) throws Exception {
			return value.myInt;

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

View raw message