add more log and set default value for pdsh/pdcp
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/a028041e Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/a028041e Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/a028041e Branch: refs/heads/master Commit: a028041e640025189be4f6ba2a1cf1d19f43086f Parents: 83b6c28 Author: Kevin Xu <[email protected]> Authored: Thu Jan 21 12:43:06 2016 +0800 Committer: Kevin Xu <[email protected]> Committed: Thu Jan 21 12:43:06 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/trafodion/libmgmt/FileMgmt.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/a028041e/core/sql/lib_mgmt/src/main/java/org/trafodion/libmgmt/FileMgmt.java ---------------------------------------------------------------------- diff --git a/core/sql/lib_mgmt/src/main/java/org/trafodion/libmgmt/FileMgmt.java b/core/sql/lib_mgmt/src/main/java/org/trafodion/libmgmt/FileMgmt.java index 093bf85..bae0702 100644 --- a/core/sql/lib_mgmt/src/main/java/org/trafodion/libmgmt/FileMgmt.java +++ b/core/sql/lib_mgmt/src/main/java/org/trafodion/libmgmt/FileMgmt.java @@ -237,17 +237,20 @@ public class FileMgmt { public static void syncJar(String userPath, String fileName) throws SQLException, IOException { checkFileName(fileName); - LOG.info("syncJars " + fileName); String nodes = System.getenv("MY_NODES"); + LOG.info("syncJars " + fileName + ", MY_NODES=" + nodes); if (nodes != null && !"".equals(nodes.trim())) { String pdcp = System.getenv("SQ_PDCP"); String pdsh = System.getenv("SQ_PDSH"); - if (pdcp != null) { - execShell(pdcp + " " + nodes + " " + userPath + fileName.trim() + " " + userPath + " "); + LOG.info("SQ_PDCP=" + pdcp + ", SQ_PDSH=" + pdsh); + if (pdcp == null) { + pdcp = "/usr/bin/pdcp"; } - if (pdsh != null) { - execShell(pdsh + " " + nodes + " chmod 755 " + userPath + fileName.trim()); + if (pdsh == null) { + pdsh = "/usr/bin/pdsh"; } + execShell(pdcp + " " + nodes + " " + userPath + fileName.trim() + " " + userPath + " "); + execShell(pdsh + " " + nodes + " chmod 755 " + userPath + fileName.trim()); } } @@ -264,6 +267,7 @@ public class FileMgmt { } private static String execShell(String cmd) throws IOException { + LOG.info("Processing command: " + cmd); Process p = Runtime.getRuntime().exec(cmd); if (p != null) { StringBuilder sb = new StringBuilder();
