You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2016/02/08 16:26:48 UTC
[3/5] storm git commit: STORM-1526 fix perf issue related to clojure
dynamic method lookup in the spout.nextTuple() call tree
STORM-1526 fix perf issue related to clojure dynamic method lookup in the spout.nextTuple() call tree
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d58ba009
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d58ba009
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d58ba009
Branch: refs/heads/master
Commit: d58ba0099f0900ffe8b45abe9f5a27e4379fb232
Parents: d5a31fc
Author: Roshan Naik <ro...@hortonworks.com>
Authored: Thu Feb 4 18:06:07 2016 -0800
Committer: Roshan Naik <ro...@hortonworks.com>
Committed: Thu Feb 4 18:06:07 2016 -0800
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/daemon/executor.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d58ba009/storm-core/src/clj/org/apache/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/executor.clj b/storm-core/src/clj/org/apache/storm/daemon/executor.clj
index afc3ea3..ab0c8aa 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/executor.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/executor.clj
@@ -58,7 +58,7 @@
(.prepare grouping context (GlobalStreamId. component-id stream-id) target-tasks)
(if (instance? LoadAwareCustomStreamGrouping grouping)
(fn [task-id ^List values load]
- (.chooseTasks grouping task-id values load))
+ (.chooseTasks ^LoadAwareCustomStreamGrouping grouping task-id values load))
(fn [task-id ^List values load]
(.chooseTasks grouping task-id values))))