storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [02/10] git commit: supervisor logs worker command with '-quoted tokens
Date Tue, 22 Apr 2014 16:39:14 GMT
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 <derekd@yahoo-inc.com>
Authored: Sun Jan 12 20:34:51 2014 +0000
Committer: Derek Dagit <derekd@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)})
       ))
 


Mime
View raw message