We had a similar issue. The way I solved it is to add a logback appender to the logger for backtype.storm.daemon.worker, and listen for a specific ‘Worker … for storm … has finished loading’ message being logged. Unfortunately, I don’t think there’s any other way of doing it, as LocalCluster does not provide a latch or other notification when the topology is actually ready to process…
From: Florian Hussonnois [mailto:[email protected]] Sent: 22 January 2015 09:36 To: [email protected] Subject: How to check if a local topology is ready ? Hi guys, For testing purpose, I deploy my topology with the LocalCluster. I would to know if there is a way to check when the topology is ready ? I try to use the method getTopologyInfo("topology_name") on my LocalCluster instance but it always throws NotAliveException? Thank you in advance -- Florian HUSSONNOIS
