You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/01/11 20:45:49 UTC
storm git commit: STORM-2153: add missing type hint
Repository: storm
Updated Branches:
refs/heads/metrics_v2 d3c00ee77 -> fea11b267
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/metrics_v2
Commit: fea11b26780dfd781f7cdb530e8ae6508afc79b4
Parents: d3c00ee
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jan 11 15:45:42 2018 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
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)))
))