Repository: storm Updated Branches: refs/heads/1.x-branch 1582c220a -> 8250a4733
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/8250a473 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8250a473 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8250a473 Branch: refs/heads/1.x-branch Commit: 8250a47336607e06c7c73c5ab1aee7ba7bcfe4ad Parents: 1582c22 Author: Roshan Naik <[email protected]> Authored: Thu Feb 4 18:06:07 2016 -0800 Committer: Jungtaek Lim <[email protected]> Committed: Tue Feb 9 11:07:28 2016 +0900 ---------------------------------------------------------------------- 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/8250a473/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 c742352..251387b 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))))
