10-1-131-131 10.1.131.132 10-1-131-132 10.1.131.133 10-1-131-133 父主题： 准备Storm应用开发环境

查看更多 →

length)]; collector.emit(new Values(sentence)); } 父主题： 开发Storm应用

查看更多 →

并且可靠性和易用性较差，因此推荐使用keytab方式。 应用开发操作步骤 确认Storm和HBase组件已经安装，并正常运行。 将storm-examples导入到IntelliJ IDEA开发环境，请参见准备Storm应用开发环境。 如果集群启用了安全服务，按登录方式分为以下两种：

查看更多 →

ucer.properties 向input中写入测试数据，可以观察到output中有对应的数据产生，则说明Storm-Kafka拓扑运行成功。 父主题： Storm应用开发常见问题

查看更多 →

管理Storm拓扑 操作场景 用户可以使用Storm的WebUI管理拓扑。“storm”用户组的用户只能管理由自己提交的拓扑任务，“stormadmin”用户组的用户可以管理所有拓扑任务。 操作步骤 访问Storm的WebUI，请参考访问Storm的WebUI。 在“Topology

查看更多 →

thrift.threads 设置主用Nimbus对外提供服务时的最大连接线程数。当Storm集群规模较大，Supervisor实例数量较多时，需要增加线程数。 512 父主题： 使用Storm

查看更多 →

样例工程文件夹storm-examples并将storm-examples导入到IntelliJ IDEA开发环境，参见准备Storm应用开发环境。 工程导入后，修改样例工程的“resources/flux-examples”目录下的“jdbc.properties”文件，根据实际环境信息修改相关参数。

查看更多 →

Storm日志介绍 本章节内容适用于 MRS 3.x及后续版本。 日志描述 日志路径：Storm相关日志的默认存储路径为“/var/log/Bigdata/storm/角色名”（运行日志），“/var/log/Bigdata/audit/storm/角色名”（审计日志）。 Nimb

查看更多 →

提交Storm拓扑 Linux中安装客户端时提交Storm拓扑 Linux中未安装客户端时提交Storm拓扑 在IDEA中提交Storm拓扑 父主题： 调测Strom应用

查看更多 →

录下的样例工程文件夹storm-examples并将storm-examples导入到IntelliJ IDEA开发环境，参见准备Storm应用开发环境。 工程导入后，修改样例工程“resources/flux-examples”目录下的“jdbc.properties”文件，根据实际环境信息修改相关参数。

查看更多 →

将storm-examples导入到Eclipse开发环境，请参见准备Storm应用开发环境。 参考storm-examples工程src/main/resources/flux-examples目录下的相关yaml应用示例，开发客户端业务。 获取相关配置文件。 本步骤只适用于业务中有访问外部组件需求的场景，如HD

查看更多 →

据。 在实际使用中推荐使用场景1中的方式，因为场景2中并非从上次commit成功的位置开始，因此可能会存在部分数据遗漏。 父主题： Storm应用开发常见问题

查看更多 →

println("word: " + word + ", count: " + count); } 父主题： 开发Storm应用

查看更多 →

执行SQL语句select * from goal; 查询“GOAL”表中的数据，如果GOAL表中有数据添加，则表明整个拓扑运行成功。 父主题： Storm应用开发常见问题

查看更多 →

kerberos.AutoTGT 执行命令：./storm upload-credentials hdfs-test 父主题： Storm应用开发常见问题

查看更多 →

kerberos.AutoTGT 执行命令：./storm upload-credentials hbase-test 父主题： Storm应用开发常见问题

查看更多 →

jar org.apache.storm.flux.Flux --remote /opt/my-topology.yaml --filter /opt/my-prop.properties 拓扑提交成功后请自行登录storm UI查看。 父主题： Storm应用开发常见问题

查看更多 →

Debug 'Unnamed'”开启调试窗口，接着开始调试，比如单步调试、查看调用栈、跟踪变量值等，如下图所示。 图5 调试 父主题： Storm应用开发常见问题

查看更多 →

--filter /opt/my-prop.properties 拓扑提交成功后请自行登录storm UI查看。 父主题： Storm应用开发常见问题

查看更多 →

Debug 'Unnamed'”开启调试窗口，接着开始调试，比如单步调试、查看调用栈、跟踪变量值等，如下图所示。 图5 调试 父主题： Storm应用开发常见问题

查看更多 →

务提交到Storm平台开启实时数据的接收、处理及结果输出；并可以在合适的时候中止业务。 高可用性 Nimbus HA机制，避免了开源Storm集群中Nimbus出现单点故障而导致集群无法提供Topology的新增及管理操作的问题，增强了集群可用性。 父主题： Storm

查看更多 →