You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/04/22 18:39:14 UTC
[02/10] git commit: supervisor logs worker command with '-quoted
tokens
supervisor logs worker command with '-quoted tokens
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/c7c7087c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/c7c7087c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/c7c7087c
Branch: refs/heads/master
Commit: c7c7087c4be7fff719e846910af1b18c48d01a38
Parents: 193301f
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Sun Jan 12 20:34:51 2014 +0000
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Wed Jan 15 03:16:52 2014 +0000
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/supervisor.clj | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/c7c7087c/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
index 9bff2ad..ea2b460 100644
--- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
@@ -469,8 +469,9 @@
(:assignment-id supervisor)
port
worker-id]
- command (->> command (map str) (filter (complement empty?)))]
- (log-message "Launching worker with command: " (clojure.string/join " " command))
+ command (->> command (map str) (filter (complement empty?)))
+ shell-cmd (->> command (map #(str \' % \')) (clojure.string/join " "))]
+ (log-message "Launching worker with command: " shell-cmd)
(launch-process command :environment {"LD_LIBRARY_PATH" (conf JAVA-LIBRARY-PATH)})
))