2015-06-06 02:32:42 event [ERROR] Error when processing event java.lang.RuntimeException: java.io.EOFException at backtype.storm.utils.Utils.deserialize(Utils.java:68) at backtype.storm.utils.LocalState.snapshot(LocalState.java:24) at backtype.storm.utils.LocalState.get(LocalState.java:28) at backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:192) at clojure.lang.AFn.applyToHelper(AFn.java:161) at clojure.lang.AFn.applyTo(AFn.java:151) at clojure.core$apply.invoke(core.clj:603) at clojure.core$partial$fn__4070.doInvoke(core.clj:2343) at clojure.lang.RestFn.invoke(RestFn.java:397) at backtype.storm.event$event_manager$fn__2507.invoke(event.clj:24) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:662) Caused by: java.io.EOFException at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2280) at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2749) at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:779) at java.io.ObjectInputStream.<init>(ObjectInputStream.java:279) at backtype.storm.utils.Utils.deserialize(Utils.java:63) ... 11 more 2015-06-06 02:32:42 event [ERROR] Error when processing event java.lang.RuntimeException: java.io.EOFException at backtype.storm.utils.Utils.deserialize(Utils.java:68) at backtype.storm.utils.LocalState.snapshot(LocalState.java:24) at backtype.storm.utils.LocalState.get(LocalState.java:28) at backtype.storm.daemon.supervisor$mk_synchronize_supervisor$this__4716.invoke(supervisor.clj:277) at backtype.storm.event$event_manager$fn__2507.invoke(event.clj:24) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:662) Caused by: java.io.EOFException at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2280) at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2749) at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:779) at java.io.ObjectInputStream.<init>(ObjectInputStream.java:279) at backtype.storm.utils.Utils.deserialize(Utils.java:63) ... 6 more 2015-06-06 02:32:42 util [INFO] Halting process: ("Error when processing an event")
http://blog.csdn.net/w13770269691/article/details/38733981
参考上文章,storm.yaml未配置storm.local.dir目录
在storm jar包中 defaults.yaml 有 storm.local.dir: "storm-local"
清空 linux 中 bin/storm-local/ 解决问题。
./storm supervisor >/dev/null 2>&1 & |
相关推荐
Supervisor是用Python开发的一套通用的进程管理程序,能将一个普通的命令行进程变为后台daemon,并监控进程状态,异常退出时能自动重启。它是通过fork/exec的方式把这些被管理的进程当作supervisor的子进程来启动,...
supervisor-event-listener Supervisor事件通知, 支持邮件, Slack, WebHook 简介 Supervisor是*nix环境下的进程管理工具, 可以把前台进程转换为守护进程, 当进程异常退出时自动重启. supervisor-event-listener监听...
收集了supervisor所需要的多个安装包,并且测试成功, 可以启动dotnetcore程序,并进行监控。
详细介绍Avaya公司CMS Supervisor 使用方法和配置技巧。
自动安装supervisor
supervisor在linux环境下的离线安装包,包括所有依赖包(不包括py,py请自行安装)
Supervisor是一个进程控制系统. 它是一个C/S系统(注意: 其提供WEB接口给用户查询和控制), 它允许用户去监控和控制在类UNIX系统的进程. 它的目标与launchd, daemontools和runit有些相似, 但是与它们不一样的是, 它...
Supervisor是用Python开发的一个client/server服务,是Linux/Unix系统下的一个进程管理工具,不支持Windows系统。它可以很方便的监听、启动、停止、重启一个或多个进程。用Supervisor管理的进程,当一个进程意外被杀...
使用Python的Supervisor进行进程监控以及自动启动
Supervisor守护进程离线脚本无脑安装
supervisor是linux下的线程守护工具,在 Linux 上有很多可以管理进程的工具,我们使用 Supervisor 来做这个事情。原因有两点: 1、它是微软官方文档推荐的,降低学习成本。 2、它并不一定是最好的,但一定是...
Ubuntu 16系统下局域网环境下supervisor 安装包,按博客步骤完成安装与配置
更多相关的main.resources: 我们的 Docker镜像启动Apache Storm。 默认情况下, storm.local.hostname属性已经设置,但是您必须提供通常需要提供的所有其他参数。不需要storm.yaml ! Storm允许您通过命令行参数...
在Linux环境中,用uwsgi+daphne+Nginx+supervisor部署Django项目,史上最全步骤
storm简单介绍、模型图及基本代码,包括nimbus、supervisor、workers、spouts、bolts等
一、 简介 二、 安装依赖 三、 安装Supervisor 四、 配置Supervisor 五、 Supervisor相关操作 六、 设置Supervisor为服务 七、 配置要管理的程序 八、 运行效果 九、 故障排除
Supervisor安装配置及问题--linux进程守护 Supervisor安装配置及问题--linux进程守护 Supervisor安装配置及问题--linux进程守护
一切就绪后,以远程模式运行 Storm,提交用于在集群中运行的Topology。 要运行Storm集群,你需要Apache Zookeeper、ØMQ、JZMQ、Java 6和Python 2.6.6。ZooKeeper用于管理集群中的不同组件,ØMQ是内部消息系统,...