[
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)
