Repository: incubator-zeppelin Updated Branches: refs/heads/master 79b2aa43a -> cd645c241
[ZEPPELIN-734] python error with certain packages ### What is this PR for? Certain python packages interact with stdout - since Zeppelin overwrites stdout to capture output, we need to make sure they have the right methods ### What type of PR is it? Bug Fix ### Todos N/A ### What is the Jira issue? https://issues.apache.org/jira/browse/ZEPPELIN-734 ### How should this be tested? Run the python code outlined in the JIRA ### Screenshots (if appropriate) N/A ### Questions: * Does the licenses files need update? No * Is there breaking changes for older versions? No * Does this needs documentation? No Author: Felix Cheung <[email protected]> Closes #778 from felixcheung/pylog and squashes the following commits: c69ffb0 [Felix Cheung] flush function Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/cd645c24 Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/cd645c24 Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/cd645c24 Branch: refs/heads/master Commit: cd645c241fd23835848d40259349d0d667cc113d Parents: 79b2aa4 Author: Felix Cheung <[email protected]> Authored: Mon Mar 14 15:06:40 2016 -0700 Committer: Lee moon soo <[email protected]> Committed: Fri Mar 18 09:35:02 2016 -0700 ---------------------------------------------------------------------- spark/src/main/resources/python/zeppelin_pyspark.py | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/cd645c24/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 9b94274..788d743 100644 --- a/spark/src/main/resources/python/zeppelin_pyspark.py +++ b/spark/src/main/resources/python/zeppelin_pyspark.py @@ -41,6 +41,9 @@ class Logger(object): def reset(self): self.out = "" + def flush(self): + pass + class PyZeppelinContext(dict): def __init__(self, zc):
