Repository: storm Updated Branches: refs/heads/master a3abb6599 -> 58050a5b3
STORM-1566 Passing File instance of path String Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ef6dfb99 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ef6dfb99 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ef6dfb99 Branch: refs/heads/master Commit: ef6dfb9943163d80ff1355e6e1cfcac977d2b8cd Parents: 4ca7522 Author: Satish Duggana <[email protected]> Authored: Mon Feb 22 12:02:26 2016 +0530 Committer: Satish Duggana <[email protected]> Committed: Mon Feb 22 12:02:26 2016 +0530 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/worker.clj | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/ef6dfb99/storm-core/src/clj/org/apache/storm/daemon/worker.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/daemon/worker.clj b/storm-core/src/clj/org/apache/storm/daemon/worker.clj index 8f9becd..db4a61a 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/worker.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/worker.clj @@ -21,6 +21,7 @@ (:require [org.apache.storm.daemon [executor :as executor]]) (:require [org.apache.storm [cluster :as cluster]]) (:require [clojure.set :as set]) + (:import [java.io File]) (:import [java.util.concurrent Executors] [org.apache.storm.hooks IWorkerHook BaseWorkerHook] [uk.org.lidalia.sysoutslf4j.context SysOutOverSLF4J]) @@ -619,7 +620,7 @@ (when-not (ConfigUtils/isLocalMode conf) (SysOutOverSLF4J/sendSystemOutAndErrToSLF4J) (let [pid (Utils/processPid)] - (FileUtils/touch (ConfigUtils/workerPidPath conf worker-id pid)) + (FileUtils/touch (File. (ConfigUtils/workerPidPath conf worker-id pid))) (spit (ConfigUtils/workerArtifactsPidPath conf storm-id port) pid))) (declare establish-log-setting-callback)
