flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [hotfix] Also use java closure cleaner on grouped operations
Date Thu, 15 Jan 2015 10:58:33 GMT
Repository: flink
Updated Branches:
  refs/heads/master 5634ee2ef -> d62ab4753


[hotfix] Also use java closure cleaner on grouped operations


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d62ab475
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d62ab475
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d62ab475

Branch: refs/heads/master
Commit: d62ab475331cac9d870a563da4f5dc091005b2c1
Parents: 5634ee2
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Jan 15 11:46:53 2015 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Thu Jan 15 11:58:03 2015 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/api/java/operators/SortedGrouping.java | 2 +-
 .../org/apache/flink/api/java/operators/UnsortedGrouping.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/d62ab475/flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java
b/flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java
index 63e5a19..57ee50c 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java
@@ -128,7 +128,7 @@ public class SortedGrouping<T> extends Grouping<T> {
 		}
 		TypeInformation<R> resultType = TypeExtractor.getGroupReduceReturnTypes(reducer,
 				this.getDataSet().getType());
-		return new GroupReduceOperator<T, R>(this, resultType, reducer, Utils.getCallLocationName()
);
+		return new GroupReduceOperator<T, R>(this, resultType, dataSet.clean(reducer), Utils.getCallLocationName()
);
 	}
 
 	

http://git-wip-us.apache.org/repos/asf/flink/blob/d62ab475/flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
b/flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
index d323eae..b8049f6 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
@@ -134,7 +134,7 @@ public class UnsortedGrouping<T> extends Grouping<T> {
 		if (reducer == null) {
 			throw new NullPointerException("Reduce function must not be null.");
 		}
-		return new ReduceOperator<T>(this, reducer, Utils.getCallLocationName());
+		return new ReduceOperator<T>(this, dataSet.clean(reducer), Utils.getCallLocationName());
 	}
 	
 	/**
@@ -156,7 +156,7 @@ public class UnsortedGrouping<T> extends Grouping<T> {
 		}
 		TypeInformation<R> resultType = TypeExtractor.getGroupReduceReturnTypes(reducer,
this.getDataSet().getType());
 
-		return new GroupReduceOperator<T, R>(this, resultType, reducer, Utils.getCallLocationName());
+		return new GroupReduceOperator<T, R>(this, resultType, dataSet.clean(reducer), Utils.getCallLocationName());
 	}
 	
 	/**


Mime
View raw message