flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [FLINK-4092] [py] Fix Stringify function's implicit string type conversion problem
Date Wed, 22 Jun 2016 09:58:05 GMT
Repository: flink
Updated Branches:
  refs/heads/master 7e206f490 -> e04239dd7


[FLINK-4092] [py] Fix Stringify function's implicit string type conversion problem

This closes #2130


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

Branch: refs/heads/master
Commit: e04239dd7397b67ce7d12ae70da8e37d4c351e4b
Parents: 7e206f4
Author: Shahin <ishahinism@gmail.com>
Authored: Sun Jun 19 14:33:14 2016 +0430
Committer: zentol <chesnay@apache.org>
Committed: Wed Jun 22 11:57:29 2016 +0200

----------------------------------------------------------------------
 .../main/python/org/apache/flink/python/api/flink/plan/DataSet.py  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e04239dd/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
b/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
index e024a38..698c236 100644
--- a/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
+++ b/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
@@ -35,7 +35,7 @@ from flink.functions.KeySelectorFunction import KeySelectorFunction
 class Stringify(MapFunction):
     def map(self, value):
         if isinstance(value, (tuple, list)):
-            return "(" + b", ".join([self.map(x) for x in value]) + ")"
+            return "(" + ", ".join([self.map(x) for x in value]) + ")"
         else:
             return str(value)
 


Mime
View raw message