You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "caofangkun (JIRA)" <ji...@apache.org> on 2015/01/26 03:34:34 UTC
[jira] [Closed] (STORM-598) Newly submitted topologies do not show
up on the storm ui cluser page when the Storm Cluster run out of worker
slots
[ https://issues.apache.org/jira/browse/STORM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
caofangkun closed STORM-598.
----------------------------
Resolution: Cannot Reproduce
> Newly submitted topologies do not show up on the storm ui cluser page when the Storm Cluster run out of worker slots
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-598
> URL: https://issues.apache.org/jira/browse/STORM-598
> Project: Apache Storm
> Issue Type: Bug
> Affects Versions: 0.9.3-rc2
> Reporter: caofangkun
> Assignee: caofangkun
> Priority: Minor
>
> 1: Set up a Storm Cluster with 1 Supervisor(4 worker slots)
> 2: submit topologyA and use 4 workers
> 3: submit topologyB with 4 workers
> topologyB does not but should show up on the storm ui cluster page.
> See Code Line 232：
> https://github.com/apache/storm/blob/master/storm-core/src/clj/backtype/storm/daemon/nimbus.clj#L1232
> If assignment is null, just new Assignmnet with 0 workers and 0 tasks?
> {code:title=nimbus.clj|borderStyle=solid}
> Index: src/clj/backtype/storm/daemon/nimbus.clj
> ===================================================================
> --- src/clj/backtype/storm/daemon/nimbus.clj (revision 4324)
> +++ src/clj/backtype/storm/daemon/nimbus.clj (working copy)
> @@ -1230,7 +1230,9 @@
> bases (topology-bases storm-cluster-state)
> topology-summaries (dofor [[id base] bases :when base]
> (let [assignment (.assignment-info storm-cluster-state id nil)
> - topo-summ (TopologySummary. id
> + topo-summ ( if (nil? assignment)
> + (TopologySummary. id (:storm-name base) 0 0 0 (time-delta (:launch-time-secs base)) (extract-status-str base))
> + (TopologySummary. id
> (:storm-name base)
> (->> (:executor->node+port assignment)
> keys
> @@ -1244,7 +1246,7 @@
> set
> count)
> (time-delta (:launch-time-secs base))
> - (extract-status-str base))]
> + (extract-status-str base)))]
> (when-let [owner (:owner base)] (.set_owner topo-summ owner))
> (when-let [sched-status (.get @(:id->sched-status nimbus) id)] (.set_sched_status topo-summ sched-status))
> topo-summ
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)