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.

{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)

Mime
View raw message