You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by mo...@apache.org on 2015/12/03 03:30:31 UTC
incubator-zeppelin git commit: [ZEPPELIN-314] pyspark is not
responding for Python 3
Repository: incubator-zeppelin
Updated Branches:
refs/heads/master bce6b89e1 -> ee6c6315c
[ZEPPELIN-314] pyspark is not responding for Python 3
This PR fixes https://issues.apache.org/jira/browse/ZEPPELIN-314, by adding parentheses to call 'print'
Author: Lee moon soo <mo...@apache.org>
Closes #493 from Leemoonsoo/ZEPPELIN-314 and squashes the following commits:
33847e7 [Lee moon soo] python3 compatible syntax
Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/ee6c6315
Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/ee6c6315
Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/ee6c6315
Branch: refs/heads/master
Commit: ee6c6315c534e73fe5cc03388755c8b47683bcf1
Parents: bce6b89
Author: Lee moon soo <mo...@apache.org>
Authored: Mon Nov 30 22:39:48 2015 +0900
Committer: Lee moon soo <mo...@apache.org>
Committed: Thu Dec 3 11:31:20 2015 +0900
----------------------------------------------------------------------
spark/src/main/resources/python/zeppelin_pyspark.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/ee6c6315/spark/src/main/resources/python/zeppelin_pyspark.py
----------------------------------------------------------------------
diff --git a/spark/src/main/resources/python/zeppelin_pyspark.py b/spark/src/main/resources/python/zeppelin_pyspark.py
index b8daa3d..1b17772 100644
--- a/spark/src/main/resources/python/zeppelin_pyspark.py
+++ b/spark/src/main/resources/python/zeppelin_pyspark.py
@@ -52,9 +52,9 @@ class PyZeppelinContext(dict):
def show(self, obj):
from pyspark.sql import DataFrame
if isinstance(obj, DataFrame):
- print gateway.jvm.org.apache.zeppelin.spark.ZeppelinContext.showDF(self.z, obj._jdf)
+ print(gateway.jvm.org.apache.zeppelin.spark.ZeppelinContext.showDF(self.z, obj._jdf))
else:
- print str(obj)
+ print(str(obj))
# By implementing special methods it makes operating on it more Pythonic
def __setitem__(self, key, item):