Repository: incubator-systemml Updated Branches: refs/heads/master 3de43d62f -> ff170f73e
[SYSTEMML-655] Utilizes java from Yarn environment Patch provided by Greg Senia Project: http://git-wip-us.apache.org/repos/asf/incubator-systemml/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-systemml/commit/ff170f73 Tree: http://git-wip-us.apache.org/repos/asf/incubator-systemml/tree/ff170f73 Diff: http://git-wip-us.apache.org/repos/asf/incubator-systemml/diff/ff170f73 Branch: refs/heads/master Commit: ff170f73e564690a390933b13409071a47c033c8 Parents: 3de43d6 Author: Luciano Resende <[email protected]> Authored: Fri Apr 29 16:22:51 2016 -0700 Committer: Luciano Resende <[email protected]> Committed: Fri Apr 29 18:44:22 2016 -0700 ---------------------------------------------------------------------- src/main/java/org/apache/sysml/yarn/DMLYarnClient.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-systemml/blob/ff170f73/src/main/java/org/apache/sysml/yarn/DMLYarnClient.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/sysml/yarn/DMLYarnClient.java b/src/main/java/org/apache/sysml/yarn/DMLYarnClient.java index 6793ead..ec5e4b0 100644 --- a/src/main/java/org/apache/sysml/yarn/DMLYarnClient.java +++ b/src/main/java/org/apache/sysml/yarn/DMLYarnClient.java @@ -27,6 +27,7 @@ import java.util.Collections; import java.util.HashMap; import java.util.Map; +import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.fs.FSDataInputStream; @@ -409,7 +410,7 @@ public class DMLYarnClient { //start command StringBuilder command = new StringBuilder(); - command.append("java"); + command.append(Environment.JAVA_HOME.$$() + "/bin/java"); //add client jvm arguments (concatenation of HADOOP_CLIENT_OPTS and HADOOP_OPTS) if( System.getenv().containsKey(JVMOPTS_ENV_CONST) ) {
