更新时间:2024-08-05 GMT+08:00

Linux中安装客户端时提交Storm拓扑

操作场景

在Linux环境下可以使用storm命令行完成拓扑的提交。

前提条件

  • 已安装Storm客户端。
  • 当客户端所在主机不是集群中的节点时,需要在客户端所在节点的hosts文件中设置主机名和IP地址映射。主机名和IP地址请保持一一对应。
  • 已执行打包Storm业务步骤,打出source.jar。

操作步骤

  1. 安全模式下,请先进行安全认证。

    1. 初始化客户端环境变量。

      进入客户端安装目录“/opt/Storm_client”执行以下命令,导入环境变量信息。

      source bigdata_env

    2. 使用在“准备开发用户”章节创建的开发用户进行安全登录。

      执行kinit命令进行“人机”用户的安全登录。

      kinit用户名

      例如:

      kinit developuser

      然后按照提示输入密码,无异常提示返回,则完成了用户的kerberos认证。

  2. 提交拓扑(以wordcount为例,其它拓扑请参照相关开发指引),进入Storm客户端“Storm/storm-1.2.1/bin”目录,将刚打出的source.jar提交(如果在Windows上进行的打包,则需要将Windows上的source.jar上传到Linux服务器,假定上传到“/opt/jartarget”目录),执行命令:storm jar /opt/jartarget/source.jar com.huawei.storm.example.wordcount.WordCountTopology
  3. 执行storm list命令,查看已经提交的应用程序,如果发现名称为word-count的应用程序,则说明任务提交成功。

    如果业务设置为本地模式,且使用命令行方式提交时,请确保提交环境为普通模式环境,当前不支持安全环境下使用命令提交本地模式的业务。