更新时间:2022-09-30 GMT+08:00

从零开始使用Storm

用户可以在MRS集群的客户端中提交和删除Storm拓扑等基本功能。

前提条件

已安装MRS集群客户端,例如安装目录为“/opt/hadoopclient”。以下操作的客户端目录只是举例,请根据实际安装目录修改。

操作步骤

  1. 根据业务情况,准备好客户端,登录安装客户端的节点。

    请根据客户端所在位置,参考安装客户端章节,登录安装客户端的节点。

  2. 执行以下命令,切换到客户端目录,例如“/opt/hadoopclient”

    cd /opt/hadoopclient

  3. 执行以下命令,配置环境变量。

    source bigdata_env

  4. 启用Kerberos认证的集群,执行以下命令认证用户身份。未启用Kerberos认证的集群无需执行。

    kinit Storm用户

  5. 执行以下命令,提交Storm拓扑:

    storm jar 拓扑包路径 拓扑Main方法的类名称 拓扑名称

    界面提示以下信息表示提交成功:

    Finished submitting topology: topo1

  6. 执行以下命令,查看Storm中的拓扑。启用Kerberos认证的集群,只有属于“stormadmin”“storm”的用户可以查看所有拓扑。

    storm list

  7. 执行以下命令,删除Storm中的拓扑。

    storm kill 拓扑名称