flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [3/4] flink git commit: [hotfix] Also use java closure cleaner on grouped operations
Date Mon, 09 Feb 2015 13:49:13 GMT
[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/95958a9b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/95958a9b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/95958a9b

Branch: refs/heads/release-0.8
Commit: 95958a9bad36574d12df8d0eb6cfbbe8d7fe8cc5
Parents: c4c3db5
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Jan 15 11:46:53 2015 +0100
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Mon Feb 9 14:48:34 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/95958a9b/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/95958a9b/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