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 2015/05/22 21:55:00 UTC
[15/18] storm git commit: STORM-596:delete extra ')' in function
loader#launch-receive-thread!
STORM-596:delete extra ')' in function loader#launch-receive-thread!
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7ab8b965
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7ab8b965
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7ab8b965
Branch: refs/heads/master
Commit: 7ab8b965ff27de917e6338f5b054946240d21c93
Parents: 42bcf30
Author: caofangkun <ca...@gmail.com>
Authored: Wed Apr 29 09:59:43 2015 +0800
Committer: caofangkun <ca...@gmail.com>
Committed: Wed Apr 29 09:59:43 2015 +0800
----------------------------------------------------------------------
pom.xml | 2 ++
storm-core/src/clj/backtype/storm/daemon/worker.clj | 4 ++--
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/7ab8b965/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 2e0c898..ad5e73e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -161,6 +161,7 @@
<module>storm-multilang/python</module>
<module>storm-multilang/ruby</module>
<module>storm-core</module>
+ <!--
<module>examples/storm-starter</module>
<module>external/storm-kafka</module>
<module>external/storm-hdfs</module>
@@ -169,6 +170,7 @@
<module>external/storm-jdbc</module>
<module>external/storm-redis</module>
<module>external/storm-eventhubs</module>
+ -->
</modules>
<scm>
http://git-wip-us.apache.org/repos/asf/storm/blob/7ab8b965/storm-core/src/clj/backtype/storm/daemon/worker.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/worker.clj b/storm-core/src/clj/backtype/storm/daemon/worker.clj
index 2943684..b5d80cc 100644
--- a/storm-core/src/clj/backtype/storm/daemon/worker.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/worker.clj
@@ -383,8 +383,8 @@
(:storm-id worker)
(:receiver-thread-count worker)
(:port worker)
- (:transfer-local-fn worker))
- :kill-fn (fn [t] (exit-process! 11)))
+ (:transfer-local-fn worker)
+ :kill-fn (fn [t] (exit-process! 11))))
(defn- close-resources [worker]
(let [dr (:default-shared-resources worker)]