默认安装storm1.0.1之后,启动一个topology任务后storm ui页面没有emit数据,查看了下nimbus日志,显示如下:
2016-07-09 06:45:41.239 o.a.s.d.nimbus [INFO] desired replication count of 1 not achieved but we have hit the max wait time 60 so moving on with replication count for conf key = 1 for code key = 1for jar key = 1
2016-07-09 06:45:41.289 o.a.s.d.nimbus [INFO] Activating yyy: yyy-1-1468071940
2016-07-09 06:45:50.182 o.a.s.s.EvenScheduler [INFO] Available slots: (["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6702] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6701] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6700] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6703] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6702] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6701] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6700])
2016-07-09 06:45:50.275 o.a.s.d.nimbus [INFO] Setting new assignment for topology id yyy-1-1468071940: #org.apache.storm.daemon.common.Assignment{:master-code-dir "/cloud/storm", :node->host {"54c29b2b-2c35-4440-8392-9ae711b24a7c" "storm2", "1997b7cd-0e4e-4854-a2d0-914a4acf6938" "storm3"}, :executor->node+port {[8 8] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6703], [12 12] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6703], [2 2] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6703], [7 7] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [3 3] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [1 1] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [6 6] ["1997b7cd-0e4e-4854-a2d0-914a4acf6938" 6703], [9 9] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [11 11] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [5 5] ["54c29b2b-2c35-4440-8392-9ae711b24a7c" 6703], [10 10] [