Configure and Start Apache Storm
![]() | Note |
|---|---|
The |
Apache Storm is fairly independent of changes to the HDP cluster, but you must upgrade Storm for rolling upgrade support in HDP-2.3.4.7 and be on the latest version of Storm.
Deactivate all running topologies.
Delete all states under zookeeper:
/usr/hdp/current/zookeeper-client/bin/zkCli.sh (optionally in secure environment specify -server zk.server:port)rmr /stormDelete all states under the storm-local directory:
rm -rf <value of storm.local.dir>Stop Storm services on the storm node.
Stop ZooKeeper services on the storm node.
su - zookeeper -c "export ZOOCFGDIR=/etc/zookeeper/conf ; export ZOOCFG=zoo.cfg ;source /etc/zookeeper/conf/zookeeper-env.sh ; /usr/lib/zookeeper/bin/zkServer.sh stop"Remove Storm and ZooKeeper from the storm node and install the HDP-2.3.4.7 version:
For RHEL/CentOS/Oracle Linux:
yum erase stormyum erase zookeeperyum install stormyum install zookeeperFor SLES:
zypper rm stormzypper rm zookeeperzypper install stormzypper install zookeeperFor Ubuntu/Debian:
apt-get remove storm --purgeapt-get remove zookeeper --purgeapt-get install stormapt-get install zookeeper
Replace your configuration after upgrading. Copy /etc/storm/conf from the template to the conf directory .
Replace your ZooKeeper configuration after upgrading. Replace the ZooKeeper template configuration in
/etc/zookeeper/conf.Start ZooKeeper. On the storm node, run the following command:
su - zookeeper -c "source /etc/zookeeper/conf/zookeeper-env.sh; export ZOOCFGDIR=/etc/zookeeper/conf; /usr/hdp/current/zookeeper-server/bin/zkServer.sh start >> $ZOO_LOG_DIR/zoo.out\"
where
$ZOO_LOG_DIR is the directory where ZooKeeper server logs are stored. For example, /var/log/zookeeper.
Start nimbus, then supervisor/ui/drpc/logviewer:
/usr/hdp/current/storm-nimbus/bin/storm nimbus.Start Storm, using a process controller, such as supervisor:
su - storm /usr/hdp/current/storm-supervisor/bin/storm supervisorYou can use the same command syntax to start Storm using nimbus/ui and logviewer.
su - storm /usr/hdp/current/storm-supervisor/bin/storm nimbussu - storm /usr/hdp/current/storm-supervisor/bin/storm uisu - storm /usr/hdp/current/storm-supervisor/bin/storm logviewersu - storm /usr/hdp/current/storm-supervisor/bin/storm drpc


![[Note]](../common/images/admon/note.png)