Repository: storm Updated Branches: refs/heads/master 26f966ca5 -> 90e811c6e
[STORM-1112] add executor-id to executor thread name Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ee1bc8a9 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ee1bc8a9 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ee1bc8a9 Branch: refs/heads/master Commit: ee1bc8a9d4fc0796e897c3b0082d35170bbca05e Parents: f0049e6 Author: zhuol <zh...@yahoo-inc.com> Authored: Wed Oct 14 16:32:44 2015 -0500 Committer: zhuol <zh...@yahoo-inc.com> Committed: Wed Oct 14 16:32:44 2015 -0500 ---------------------------------------------------------------------- storm-core/src/clj/backtype/storm/daemon/executor.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/ee1bc8a9/storm-core/src/clj/backtype/storm/daemon/executor.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj index 746fde3..c79949b 100644 --- a/storm-core/src/clj/backtype/storm/daemon/executor.clj +++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj @@ -685,7 +685,7 @@ 0)) :kill-fn (:report-error-and-die executor-data) :factory? true - :thread-name component-id)])) + :thread-name (str component-id "-executor" (:executor-id executor-data)))])) (defn- tuple-time-delta! [^TupleImpl tuple] (let [ms (.getProcessSampleStartTime tuple)] @@ -899,7 +899,7 @@ 0))) :kill-fn (:report-error-and-die executor-data) :factory? true - :thread-name component-id)])) + :thread-name (str component-id "-executor" (:executor-id executor-data)))])) (defmethod close-component :spout [executor-data spout] (.close spout))
