You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/05/04 12:44:20 UTC
[2/7] flink git commit: [hotfix] [py] Code cleanup - Functions
[hotfix] [py] Code cleanup - Functions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36950629
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36950629
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/36950629
Branch: refs/heads/master
Commit: 369506291a483158bd041f31ebcfc6e7fe86a263
Parents: 3655dee
Author: zentol <ch...@apache.org>
Authored: Thu Apr 20 13:26:38 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Thu May 4 12:56:39 2017 +0200
----------------------------------------------------------------------
.../flink/python/api/functions/util/IdentityGroupReduce.java | 2 ++
.../org/apache/flink/python/api/functions/util/SerializerMap.java | 2 +-
2 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/36950629/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/IdentityGroupReduce.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/IdentityGroupReduce.java b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/IdentityGroupReduce.java
index 1e7bbe6..32fd22a 100644
--- a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/IdentityGroupReduce.java
+++ b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/IdentityGroupReduce.java
@@ -12,12 +12,14 @@
*/
package org.apache.flink.python.api.functions.util;
+import org.apache.flink.api.java.functions.FunctionAnnotation.ForwardedFields;
import org.apache.flink.util.Collector;
import org.apache.flink.api.common.functions.GroupReduceFunction;
/*
Utility function to group and sort data.
*/
+@ForwardedFields("*->*")
public class IdentityGroupReduce<IN> implements GroupReduceFunction<IN, IN> {
@Override
public final void reduce(Iterable<IN> values, Collector<IN> out) throws Exception {
http://git-wip-us.apache.org/repos/asf/flink/blob/36950629/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/SerializerMap.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/SerializerMap.java b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/SerializerMap.java
index 9c39e5f..116efd4 100644
--- a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/SerializerMap.java
+++ b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/util/SerializerMap.java
@@ -20,7 +20,7 @@ import org.apache.flink.python.api.streaming.util.SerializationUtils.Serializer;
Utility function to serialize values, usually directly from data sources.
*/
public class SerializerMap<IN> implements MapFunction<IN, byte[]> {
- private Serializer<IN> serializer = null;
+ private transient Serializer<IN> serializer;
@Override
@SuppressWarnings("unchecked")