storm的worker自动重启

来源：12-9 -Storm整合Kafka功能开发

慕函数7570418

2019-11-28

图片描述
老师您好，我想问一下我这个storm它跑着跑着其中一个worker的进程端口显示worker重启了然后我的storm就跑到一半不跑了数据还没计算完。这个是为什么啊？我设置supervisor.worker.timeout.sec = 60 是这个不够吗日志显示也没啥问题疑惑不解

写回答

1回答

Michael_PK

2019-11-29

已采纳

storm是具备自动重启的功能的，不太确定具体是什么原因呢。你对接的是kafka数据吗？如果是，确认下offset是否都消费完了，如果消费完了那就OK，如果没完，那得定位具体问题了

慕函数7570418

非常感谢！

2020-03-26

共7条回复

Java大数据实战，巧用Storm快速切入实时流处理领域

深入Storm内部机制，logstash+kafka，快速切入大数据实时流处理

518 学习 · 143 问题

相似问题

回答 1

回答 1

回答 8

回答 1

回答 1