更新时间:2022-09-30 GMT+08:00
从零开始使用Storm
用户可以在MRS集群的客户端中提交和删除Storm拓扑等基本功能。
前提条件
已安装MRS集群客户端,例如安装目录为“/opt/hadoopclient”。以下操作的客户端目录只是举例,请根据实际安装目录修改。
操作步骤
- 根据业务情况,准备好客户端,登录安装客户端的节点。
请根据客户端所在位置,参考安装客户端章节,登录安装客户端的节点。
- 执行以下命令,切换到客户端目录,例如“/opt/hadoopclient”。
cd /opt/hadoopclient
- 执行以下命令,配置环境变量。
source bigdata_env
- 启用Kerberos认证的集群,执行以下命令认证用户身份。未启用Kerberos认证的集群无需执行。
kinit Storm用户
- 执行以下命令,提交Storm拓扑:
storm jar 拓扑包路径 拓扑Main方法的类名称 拓扑名称
界面提示以下信息表示提交成功:
Finished submitting topology: topo1
- 执行以下命令,查看Storm中的拓扑。启用Kerberos认证的集群,只有属于“stormadmin”或“storm”的用户可以查看所有拓扑。
storm list
- 执行以下命令,删除Storm中的拓扑。
storm kill 拓扑名称
父主题: 使用Storm