博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
测试storm异常信息(时时更新)
阅读量:7046 次
发布时间:2019-06-28

本文共 710 字,大约阅读时间需要 2 分钟。

Exception in thread "main" java.lang.RuntimeException: org.apache.thrift7.protocol.TProtocolException: Required field 'supervisor_id' is unset! Struct:SupervisorSummary(host:hslave1, uptime_secs:531, num_workers:8, num_used_workers:0, supervisor_id:null) 

解决方法:原因是服务器用的storm版本与客户端使用的storm版本不一致,统一storm版本后问题解决

 

Storm的启动:

1、Nimbus: Storm主控节点上运行"bin/storm nimbus >/dev/null 2>&1 &"启动Nimbus后台程序,并放到后台执行;

2Supervisor: Storm工作节点上运行"bin/storm supervisor >/dev/null 2>&1 &"启动Supervisor后台程序,并放到后台执行;

3UI: Storm主控节点上运行"bin/storm ui >/dev/null 2>&1 &"启动UI后台程序,并放到后台执行,启动后可以通过http://{nimbus host}:8080观察集群的worker资源使用情况、Topologies的运行状态等信息。

 

 defaults.yaml

https://github.com/nathanmarz/storm/blob/master/conf/defaults.yaml

转载地址:http://wbzol.baihongyu.com/

你可能感兴趣的文章
jQuery替换内容
查看>>
空暇时候思考2('\0'等价于数字0还是字符0)
查看>>
英语词汇周计划(1-1)group 1
查看>>
FreeRTOS基础知识
查看>>
3.从AbstractQueuedSynchronizer(AQS)说起(2)——共享模式的锁获取与释放
查看>>
关于逻辑或的一个小小应用注意点
查看>>
(一)Redis笔记——简介 、key 、数据类型
查看>>
第四篇:Web框架 - Django
查看>>
第九篇:随机森林(Random Forest)
查看>>
crontab命令详解
查看>>
高可用架构的6大常规方案【转】
查看>>
编程中的匈牙利命名法
查看>>
nj06---包
查看>>
Batch normalization:accelerating deep network training by reducing internal covariate shift的笔记
查看>>
Nginx/LVS/HAProxy负载均衡软件的优缺点详解
查看>>
Java -Xms -Xmx -Xss -XX:MaxNewSize -XX:MaxPermSize含义记录
查看>>
微信小程序开发之常见BUG
查看>>
汇编指令-MRS(读)和MSR(写)指令操作CPSR寄存器和SPSR寄存器使用(1)
查看>>
Instagram的Material Design概念设计文章分享
查看>>
Jersey VS Django-Rest
查看>>