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 2016/10/19 22:06:33 UTC
zeppelin git commit: [ZEPPELIN-1314] dump out the R command
Repository: zeppelin
Updated Branches:
refs/heads/master fab3e5ff9 -> ab4463381
[ZEPPELIN-1314] dump out the R command
This PR replaces https://github.com/apache/zeppelin/pull/1309/
Author: Chris Snow <ch...@gmail.com>
Closes #1531 from snowch/snowch-patch-1 and squashes the following commits:
f5f7a70 [Chris Snow] use toString() method of CommandLine for logging
09a6d23 [Chris Snow] added missing semi-colon for statement
25e8a29 [Chris Snow] [ZEPPELIN-1314] dump out the R command
Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/ab446338
Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/ab446338
Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/ab446338
Branch: refs/heads/master
Commit: ab446338197443eee0f9d2ba4dd1c06a3320e4c0
Parents: fab3e5f
Author: Chris Snow <ch...@gmail.com>
Authored: Tue Oct 18 05:56:25 2016 +0100
Committer: Lee moon soo <mo...@apache.org>
Committed: Thu Oct 20 07:06:19 2016 +0900
----------------------------------------------------------------------
spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/ab446338/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java
----------------------------------------------------------------------
diff --git a/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java b/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java
index 2648833..961793d 100644
--- a/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java
+++ b/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java
@@ -141,6 +141,9 @@ public class ZeppelinR implements ExecuteResultHandler {
cmd.addArgument(Integer.toString(port));
cmd.addArgument(libPath);
cmd.addArgument(Integer.toString(sparkVersion.toNumber()));
+
+ // dump out the R command to facilitate manually running it, e.g. for fault diagnosis purposes
+ logger.debug(cmd.toString());
executor = new DefaultExecutor();
outputStream = new SparkOutputStream(logger);