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 <[email protected]> Authored: Thu Feb 4 18:06:07 2016 -0800 Committer: Roshan Naik <[email protected]> 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))))
