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/23 17:16:05 UTC
[4/7] storm git commit: Fixing accidental revert.
Fixing accidental revert.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/965da06a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/965da06a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/965da06a
Branch: refs/heads/master
Commit: 965da06a5997773ea5401d73e48e203f4db46727
Parents: ba6eed0
Author: Kyle Nusbaum <kn...@yahoo-inc.com>
Authored: Thu Feb 5 09:20:02 2015 -0600
Committer: Kyle Nusbaum <kn...@yahoo-inc.com>
Committed: Thu Feb 5 09:20:02 2015 -0600
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/965da06a/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index f0bef92..ec68d45 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -60,7 +60,7 @@
))
(defn- mk-grouper
- "returns a function that returns a vector of which task indices to send tuple to, or just a single task index."
+ "Returns a function that returns a vector of which task indices to send tuple to, or just a single task index."
[^WorkerTopologyContext context component-id stream-id ^Fields out-fields thrift-grouping ^List target-tasks]
(let [num-tasks (count target-tasks)
random (Random.)