知识点
相关文章
更多最近更新
更多storm0.9-single
2019-03-02 23:43|来源: 网路
参考
http://shiyanjun.cn/archives/241.html
用新版包自己做了一遍
(1)安装zeromq4&jzmq
[安装依赖]
yum install uuid*
yum install libtool
yum install libuuid
yum install libuuid-devel
[安装zeromq]
cd zeromq-4.0.4
./configure (不要使用--prefix指定路径,我试着在这里指定了一下结果后面jzmq就找不到zmq.h)
make
make install
[安装jzmq]
git clone git://github.com/nathanmarz/jzmq.git
cd jzmq/
./autogen.sh
./configure
make
make install
(2)安装zookeeper
vi ~/.bashrc
#ZooKeeper
export ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.6
export PATH=$PATH:$ZOOKEEPER_HOME/bin
source ~/.bashrc
(3)安装storm
[环境变量]
vi ~/.bashrc
#Storm
export STORM_HOME=/home/hadoop/soft/apache-storm-0.9.1-incubating
export PATH=$PATH:$STORM_HOME/bin
source ~/.bashrc
[配置]
vi ./conf/storm.yaml (注意yaml格式的要求,空格tab,:和-前后都有空格)
storm.zookeeper.servers:
- "localhost"
storm.zookeeper.port : 2181
nimbus.host : "localhost"
storm.local.dir : "/home/hadoop/soft/apache-storm-0.9.1-incubating/tmp"
supervisor.slots.ports:
- 6700
- 6701
- 6702
(4)运行示例
[下载示例源码编译打包]
git clone https://github.com/nathanmarz/storm-starter.git
cd storm-starter/
mvn -f m2-pom.xml package
[启动服务]
启动zookeeper
./zkServer.sh start
启动storm
storm help 可以看到有很多的命令
Commands:
activate
classpath
deactivate
dev-zookeeper
drpc
help
jar
kill
list
localconfvalue
logviewer
nimbus
rebalance
remoteconfvalue
repl
shell
supervisor
ui
version
Help:
help
help <command>
storm nimbus (启动积雨云)
storm supervisor (启动工作节点)
storm ui (启动web界面)
[hadoop@localhost logs]$ netstat -an|grep 6700
[hadoop@localhost logs]$ netstat -an|grep 6701
[hadoop@localhost logs]$ netstat -an|grep 6702
此时三个工作端口均未启动
web界面查看
http://localhost:8080/
[不带Topology名提交Topology]
storm jar ../storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology
这中情况不会提交到nimbus去运行
[提交Topology]
storm jar ../storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology myFirstStormApp
[查看Topology]
storm list
Topology_name Status Num_tasks Num_workers Uptime_secs
-------------------------------------------------------------------
myFirstStormApp ACTIVE 28 3 26063
[提交同名的Topology]
Exception in thread "main" java.lang.RuntimeException: Topology with name `myFirstStormApp` already exists on cluster
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:89)
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:58)
at storm.starter.WordCountTopology.main(WordCountTopology.java:77)
[杀死Topology]
Topology_name Status Num_tasks Num_workers Uptime_secs
-------------------------------------------------------------------
myFirstStormApp KILLED 0 0 26126
过一段时间后
No topologies running.
(5)日志查看
tail
-100f logs/nimbus.log
tail
-100f logs/
supervisor
.log
tail
-100f logs/
worker-6700.log
tail
-100f logs/
worker-6701.log
tail
-100f logs/
worker-6702.log
转自:http://www.cnblogs.com/really-dt/p/3775663
相关问答
更多-
有storm相关的视频可以下载的吗?[2022-03-14]
bg4.png storm的,这方面不多,有资料可以参考 Storm入门指南 基于Storm进行实时网络攻击检测及数据挖掘文档下载 hadoop、storm、数据挖掘等文档分享 storm实时流计算应用开发框架-天罡从需求到技术方案介绍 hadoop、hive、storm文档、电子书籍分享 storm编程入门:基本概念 hadoop、storm、hbase面试题、工作日常问答 Storm相关20文档与相关包 Storm入门教程汇总 -
请问dance up a storm具体怎么翻译?[2022-06-05]
Hi: 下列还有三个短语相同意思: cook up a storm烹饪上露一手 dance up a storm舞姿翩翩 talk up a storm 侃侃而谈 [MAINLY US INFORMAL:主要用于美国,非正式用语] to do something with a lot of energy and often skill:[以非凡的能力和技能做某事] Rob was in the kitchen cooking up a storm. Rob在厨房里大显身手. (from Cambridge ... -
when the rain,the storm all is up怎么翻译[2022-01-20]
当下雨的时候,风暴都到了 -
Storm是什么文件[2023-06-19]
Storm译为汉语即‘暴风雨’、“暴风雪”,是暴风影音软件的英文名,是一种媒体播放器。 Storm还是一个分布式的、容错的实时计算系统,由BackType开发,广泛用于进行实时日志处理,实时统计、实时风控、实时推荐等场景中,目前最新版本是Storm 0.8.0。 Storm还是外文歌曲的名字,具体可在百度音乐中搜索。 -
如果将变量从Single更改为Double,则似乎不会出现此问题。 我认为编译器正在将0.9转变为双精度。 但您也可以使用以下方法将0.9转换为单个: If my_variable < CSng(0.9) Then 或者您可以通过使用字母F告诉编译器它是单一的( https://docs.microsoft.com/en-us/dotnet/visual-basic/programming-guide/language-features/data-types/type - 人物 ) If my_variab ...
-
是的,这是可能的。 您可以站起来运行Storm的“单节点集群”,它可以在一台机器上运行。 这将模拟真正的集群会是什么样的,但是您将有1台机器托管整个堆栈(ZooKeeper和Storm)。 本质上,Nimbus服务器是您的工作服务器。 配置它与此指南相同: https : //github.com/nathanmarz/storm/wiki/Setting-up-a-Storm-cluster 。 基本上一切都将是您的localhost机器。 Maven是一个构建工具,用于从源代码构建软件(它也可以执行其他 ...
-
我想稍微延长丹的答案。 运行此代码: clear all; x0=0.5; x2=0.9; h=0.1; while(x0
如何使用blitz_0.9(how to use blitz_0.9)[2023-05-22]
你确定你不只是编译库的静态版本吗? 如果没有,则会生成.dll。 也许你可以显示你用来构建库的命令。 Are you sure you didn't just compile the static version of the library? If so no .dll will be produced. Perhaps you can show the commands you used to build the library.你只使用一个Nimbus实例的原因是什么? 是因为它的升级吗? 我的意思是我喜欢HA nimus的容错架构,如果它可能,那么就应该选择配置分布式状态存储的主动和备用路由。 What is the reason for your using just 1 instance of Nimbus ? Is it because its staging ? I mean i liked HA nimus' fault tolerant architecture and if its possible then sh ...只需按照群集设置指南操作: https://storm.apache.org/documentation/Setting-up-a-Storm-cluster.html 对于伪分布式设置,请在单台计算机中运行所有守护程序(ZK,Nimbus和一个单独的主管)。 Just follow the cluster setup guide: https://storm.apache.org/documentation/Setting-up-a-Storm-cluster.html For pseudo distri ...