STORM-2153: add missing type hint
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/fea11b26 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/fea11b26 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/fea11b26 Branch: refs/heads/1.x-branch Commit: fea11b26780dfd781f7cdb530e8ae6508afc79b4 Parents: d3c00ee Author: P. Taylor Goetz <[email protected]> Authored: Thu Jan 11 15:45:42 2018 -0500 Committer: P. Taylor Goetz <[email protected]> Committed: Thu Jan 11 15:45:42 2018 -0500 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/task.clj | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/fea11b26/storm-core/src/clj/org/apache/storm/daemon/task.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/daemon/task.clj b/storm-core/src/clj/org/apache/storm/daemon/task.clj index 26ce76c..68af75b 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/task.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/task.clj @@ -163,7 +163,7 @@ ))) (apply-hooks user-context .emit (EmitInfo. values stream task-id out-tasks)) (when (emit-sampler) - (stats/emitted-tuple! executor-stats (.getEmitted (.get ^Map (:task-metrics executor-data) task-id) stream) stream) + (stats/emitted-tuple! executor-stats (.getEmitted ^TaskMetrics (.get ^Map (:task-metrics executor-data) task-id) stream) stream) (stats/transferred-tuples! executor-stats (.getTransferred ^TaskMetrics (.get ^Map (:task-metrics executor-data) task-id) stream) stream (count out-tasks))) out-tasks))) ))
