twitter storm学习 - 安装部署问题汇总
已经碰到的或者将来碰到的关于安装部署方面的问题以及解决方法,先挖个坑
1.提交的topology在admin界面上看emitted始终都是0,查看日志发现有如下错误:
worker [ERROR] Error on initialization of server mk-worker
org.zeromq.ZMQException: 无效的参数(0x16)
at org.zeromq.ZMQ$Socket.setLongSockopt(Native Method)
at org.zeromq.ZMQ$Socket.setLinger(ZMQ.java:601)
at zilch.mq$set_linger.invoke(mq.clj:57)
at backtype.storm.messaging.zmq.ZMQContext.connect(zmq.clj:62)
at backtype.storm.daemon.worker$mk_refresh_connections$this__4293$iter__4300__4304$fn__4305.invoke(worker.clj:244)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.RT.seq(RT.java:473)
at clojure.core$seq.invoke(core.clj:133)
at clojure.core$dorun.invoke(core.clj:2725)
at clojure.core$doall.invoke(core.clj:2741)
at backtype.storm.daemon.worker$mk_refresh_connections$this__4293.invoke(worker.clj:238)
at...
我的zeromq版本是3.X ,查资料后看到有说法可能是zeromq的版本问题,按照建议下载2.7.1版本,并重新安装zeromq以及jzmq,重启nimbus和supervisor节点,重新commit测试的topology,执行成功,日志也没有错误了。
2. 安装并编译zeromq出错:
make报错:cannot link with -luuid, install uuid-dev.
原来是缺少库,尝试yum install uuid-dev,找不到这个库
bing了一下,原来uuid-dev在不同的平台上名字不同,我用的centos上名字为libuuid-devel
执行yum install libuuid-devel ...
下载并安装成功!
3. 在eclipse中编译storm-starter示例代码出错:
import backtype.storm.task.IMetricsContext 找不到.
自己判断是引用的storm.jar版本问题,把我引用的0.8.1版本的jar包换成0.7的,结果错误更多,一查发现搞反了,应该用更新的jar包,于是下载0.8.2版本的编译,错误消除!
4. drpc示例代码调用错误
像服务器上部署了storm-starter的BasicDRPCTopology,
使用客户端代码尝试连接drpc server发送参数并获取结果
DRPCClient client= new DRPCClient("192.168.72.203",3772);
String result = client.execute("basicdprc","goodbye");
System.out.println(result);
192.168.72.203是我在服务端配置的drpc服务器的ip
代码执行到execute以后停住,很长时间都无法执行,到服务端查看drpc.log日志,有如下错误:
TNonblockingServer [WARN] Got an IOException in internalRead!
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:218)
at sun.nio.ch.IOUtil.read(IOUtil.java:191)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:359)
at org.apache.thrift7.transport.TNonblockingSocket.read(TNonblockingSocket.java:141)
at org.apache.thrift7.server.TNonblockingServer$FrameBuffer.internalRead(TNonblockingServer.java:669)
at org.apache.thrift7.server.TNonblockingServer$FrameBuffer.read(TNonblockingServer.java:458)
at org.apache.thrift7.server.TNonblockingServer$SelectThread.handleRead(TNonblockingServer.java:359)
at org.apache.thrift7.server.TNonblockingServer$SelectThread.select(TNonblockingServer.java:304)
at org.apache.thrift7.server.TNonblockingServer$SelectThread.run(TNonblockingServer.java:243)
折腾了一天多,最终解决了这个诡异的问题,错误原因出奇的简单:
BasicDRPCTopology代码中声明new LinearDRPCTopologyBuilder("exclamation");
指定了topology的name为exclamation
而我在手动使用./storm jar...参数提交的时候指定的名字是basicdprc,提交topology的时候是正常的,在storm
ui管理界面里看到此topology的名字也是basicdprc,但是DRPCClient调用execute的时候却必须使用代码中指定的名称... 改成 client.execute("exclamation","goodbye");就可以顺利调用了。
神那,怎么会这样!!!既然允许参数指定提交的topology名称,那drpcclient也应该允许使用此名称啊!!这种限制简直要让人撞墙!!
5. storm.yaml配置文件格式错误:
yaml配置文件的格式要求比较变态:
配置键值对 的时候,冒号后面需要有一个空格,不能直接跟值,否则解析的时候会报错:
例如 storm.zookeeper.port: 2183 2183和冒号间就需要有一空格
另外行的开头前面也需要有空格...
最新文章
- Android异常:唤醒锁未授权。(Caused by: java.lang.SecurityException: Neither user 10044 nor current process has android.permission.WAKE_LOCK.)
- Visual Studio Online Integrations
- C#虚方法认识
- 邻接表实现Dijkstra算法以及DFS与BFS算法
- 测试ODBC与OLE
- Linux下动态调整LVM文件系统大小
- wpf 资源的重用
- 【剑指offer】Q40:数组中出现一次的数
- js--局部变量
- Tomcat 部署项目的三种方法
- js 标签云
- Beat冲刺报告---Day0
- Bate敏捷冲刺每日报告--day5
- ELK 架构之 Elasticsearch、Kibana、Logstash 和 Filebeat 安装配置汇总(6.2.4 版本)
- Abd学习笔记
- 贪心之oj.1797
- Java知多少(64)线程死锁
- [转]一个故事讲清楚NIO
- 【校招面试 之 C/C++】第33题 C++ 11新特性(四)之STL容器
- MVC 在action方法中获取当前action的控制器名和action名
热门文章
- (树)根据排序数组或者排序链表重新构建BST树
- Customizing Site-Wide Behavior for ASP.NET Web Pages (Razor) Sites
- C# 操作Excel基础篇(读取Excel、写入Excel)
- Java web 中的HttpServletRequest对象
- Linux下的多线程下载工具mwget
- Sort函数(C++)
- Android Butterknife框架 注解攻略
- bitbucket使用教程
- 以太坊系列之十八: 百行go代码构建p2p聊天室
- 小规模kvm宿主机管理-webvirtmgr安装