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/02/02 21:12:40 UTC
[1/2] storm git commit: STORM-527: update worker.clj -- delete
"missing-tasks" checking
Repository: storm
Updated Branches:
refs/heads/master a115c9df8 -> 5e7d812ed
STORM-527: update worker.clj -- delete "missing-tasks" checking
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b610e3c2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b610e3c2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b610e3c2
Branch: refs/heads/master
Commit: b610e3c2b9c12006a3c1826878072414d3497ce9
Parents: a115c9d
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Feb 2 14:09:33 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Feb 2 14:09:33 2015 -0600
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/worker.clj | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/b610e3c2/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 e717ce4..8bba5e4 100644
--- a/storm-core/src/clj/backtype/storm/daemon/worker.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/worker.clj
@@ -312,11 +312,7 @@
#(HashMap. (apply dissoc (into {} %1) %&))
remove-connections)
- (let [missing-tasks (->> needed-tasks
- (filter (complement my-assignment)))]
- (when-not (empty? missing-tasks)
- (log-warn "Missing assignment for following tasks: " (pr-str missing-tasks))
- )))))))
+ )))))
(defn refresh-storm-active
([worker]
[2/2] storm git commit: Added STORM-527 to Changelog and Readme
Posted by bo...@apache.org.
Added STORM-527 to Changelog and Readme
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5e7d812e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5e7d812e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5e7d812e
Branch: refs/heads/master
Commit: 5e7d812edff8fc24fccdf854bb0f4e28b233515f
Parents: b610e3c
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Feb 2 14:11:50 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Feb 2 14:11:50 2015 -0600
----------------------------------------------------------------------
CHANGELOG.md | 1 +
README.markdown | 1 +
2 files changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/5e7d812e/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index d6c886d..f7f9699 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -37,6 +37,7 @@
* STORM-630: Support for Clojure 1.6.0
* STORM-629: Place Link to Source Code Repository on Webpage
* STORM-632: New grouping for better load balancing
+ * STORM-527: update worker.clj -- delete "missing-tasks" checking
## 0.9.3-rc2
* STORM-558: change "swap!" to "reset!" to fix assignment-versions in supervisor
http://git-wip-us.apache.org/repos/asf/storm/blob/5e7d812e/README.markdown
----------------------------------------------------------------------
diff --git a/README.markdown b/README.markdown
index 7c6c26c..cb3a7eb 100644
--- a/README.markdown
+++ b/README.markdown
@@ -186,6 +186,7 @@ under the License.
* Rick Kilgore ([@rick-kilgore](http://github.com/rick-kilgore))
* 周向涛 ([@taojoe](https://github.com/taojoe))
* Gianmarco De Francisci Morales ([@gdfm](https://github.com/gdfm))
+* zhangjinlong ([@BuDongDong](https://github.com/BuDongDong))
## Acknowledgements