首页 > 其他分享 >storm-0.9.3 wordcount例子运行步骤(单机版)

storm-0.9.3 wordcount例子运行步骤(单机版)

时间:2023-04-25 21:02:08浏览次数:65  
标签:0.9 单机版 Storm jar wordcount storm apache starter


网上关于Storm wordcount的例子很多,不过都是基于storm-0.9.0.1,在运行例子过程中torm 0.9.0.1.jar在maven中央仓库没有找到只有0.9.3,在运行过程中出现了好多问题。所以记下笔记。方便以后查看。

1,  下载Storm,地址为http://www.apache.org/dyn/closer.cgi/storm/apache-storm-0.9.3/apache-storm-0.9.3.tar.gz
         Storm用于将JAR包和Topology的主类提交给nimbus
2,    解压:apache-storm-0.9.3.tar.gz.
3,进入目录apache-storm-0.9.3执行命令:mvn clean install -DskipTests=true 下载依赖jar包
4,编译例子:mvn compile exec:java -Dstorm.topology=storm.starter.WordCountTopology
5,将编译后的jar复制到storm的bin目录:storm-starter-0.9.3-jar-with-dependencies.jar
6,执行:storm jar storm-starter-0.9.3-jar-with-dependencies.jar   storm.starter.WordCountTopology -c nimbus.host=localhost 
7,打开storm ui,可以看到对应的Topology,则发布成功

注意:在下载依赖jar的过程中可能部分jar包,找不到,则从storm的安装目录copy的.m2中。其中rely.jar实在找不到。。 为了测试暂且把一个jar改名为reply.jar来进行编译了。。。。




参考:http://blog.sina.com.cn/s/blog_772f8d010100zm4d.html

http://www.jdon.com/bigdata/stormwin.html


标签:0.9,单机版,Storm,jar,wordcount,storm,apache,starter
From: https://blog.51cto.com/u_16088628/6225151

相关文章

  • WordCountTopology 执行日志分析
    1,代码packagestorm.starter;importbacktype.storm.Config;importbacktype.storm.LocalCluster;importbacktype.storm.StormSubmitter;importbacktype.storm.task.ShellBolt;importbacktype.storm.topology.BasicOutputCollector;importbacktype.storm.topology.I......
  • hello flume (Ubuntu 下 flume1.5单机版安装以及简单入门示例)
    1,下载最新的flume安装包:wgethttp://www.apache.org/dist/flume/stable/apache-flume-1.5.2-bin.tar.gz2,在安装目录解压:tar-zxvfapache-flume-1.5.2-bin.tar.gz3,设置环境变量exportJAVA_HOME=/usr;exportFLUME_HOME=/home/joeyon/apache-flume-1.5.2-bin;exportPATH=$PAT......
  • 0.96寸OLED使用 sprintf() 显示动态变化数字
    显示语句OLED 可以用sprintf() 函数输出的字符串来显示动态变化的数字。例如,可以定义一个u8charoled_buff[20],作为sprintf()的第1个输入参数,第2、3个参数可按 printf() 函数的格式写。然后在将oled_buff 作为 OLED_ShowString() 的参数(第1、2个参数为坐标,第3个为要......
  • hadoop伪分布式集群的安装(不是单机版)
    准备工作三台虚拟机,关闭防火墙,关闭selinux查看防火状态systemctlstatusfirewalld暂时关闭防火墙systemctlstopfirewalld永久关闭防火墙systemctldisablefirewalld查看selinux状态getenforce暂时关闭selinuxsetenforce0永久关闭selinux在/etc/selinux/confi......
  • macOS 13.4Beta 2 OpenCore 0.9.2双引导分区原版黑苹果镜像
    镜像特点文章原地址:http://www.imacosx.cn/113041.html(转载请注明出处)完全由黑果魏叔官方制作,针对各种机型进行默认配置,让黑苹果安装不再困难。系统镜像设置为双引导分区,全面去除clover引导分区(如有需要,可以自行直接替换opencore分区文件为clover引导文件)备注:此镜像仅适用与16g优盘......
  • 制作firebird for linux aarch64/loonarch64单机版deb安装包
    firebird是一个全功能的,强大高效的,轻量级,免维护的数据库,下面简单介绍firebird作为单机版时怎样制作deb安装包(firebird编译见:https://www.cnblogs.com/qiufeng2014/p/16593961.html)。制作安装包有2点要注意:1、设置依赖包:libtommath-dev,libmcrypt-dev,libtomcrypt-dev2、将libEngin......
  • macOS 13.3.1 (22E261)With OpenCore 0.9.2开发版 and winPE双引导分区原版镜像
    镜像特点原文来源于黑果魏叔官网,转载需注明出处。(下载请直接百度黑果魏叔)完全由黑果魏叔官方制作,针对各种机型进行默认配置,让黑苹果安装不再困难。系统镜像设置为双引导分区,全面去除clover引导分区(如有需要,可以自行直接替换opencore分区文件为clover引导文件)备注:此镜像仅适用与16g......
  • ansible-playbook之安装elasticsearch单机版
    一.准备环境:1.centos7环境2.安装ansible环境3.elasticsearch安装文件下载路径:  https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-8.6.2-linux-x86_64.tar.gz4.elasticsearch安装主机,作者用192.168.126.129作为elasticsearch安装环境二.规划:1.变量规......
  • StreamSets单机版安装文档
    StreamSets单机版安装文档解压安装包到opt目录tar-zxvfstreamsets-datacollector-common-3.22.3.tgz-C/opt修改为sdc配置为表单认证cd/opt/streamsets-datacollector-3.22.3/vietc/sdc.propertieshttp.authentication=form后台启动nohup./bin/streamsets......
  • GBase 8a 单机版安装教程
    GBase8a单机免费版安装。本文采用官方免费版本GBase8a-NoLicense-Free-8.6.2_build43-R7-redhat7.3-x86_64.tar.bz2为例,介绍单机版安装步骤。安装包下载地址https://pan......