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 2016/06/22 09:58:05 UTC
flink git commit: [FLINK-4092] [py] Fix Stringify function's implicit
string type conversion problem
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 <is...@gmail.com>
Authored: Sun Jun 19 14:33:14 2016 +0430
Committer: zentol <ch...@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)