首页   注册   登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX  ›  Storm

如果修改了 storm 的 spout 和 bolt 代码,就 kill 掉作业,重新提交吧。那么 kill 作业的时候如何做 cleanup 的工作呢?

  •  
  •   codingpp · 2014-06-12 14:05:32 +08:00 · 3495 次点击
    这是一个创建于 1680 天前的主题,其中的信息可能已经有所发展或是发生改变。
    我的作业是这样的:
    spout收集日志->bolt汇总日志并每隔1秒钟插入数据库
    每条日志都需要处理不能丢
    kill task的时候spout的会先置为失效,这时候就没有消息推送到bolt中了。然后再停止掉
    bolt中没有数据推送过来,所以就不会再触发process方法了
    那么这1秒钟内数据将没法插入到数据库里了
    storm里的cleanup方法貌似只能工作在本地模式下,那么我想要在分布式模式下kill作业的时候做下cleanup的处理该如何做呢?
    5 回复  |  直到 2014-08-01 09:48:48 +08:00
        1
    codingpp   2014-06-12 14:09:44 +08:00
    v2ex的大神们有用storm的吗
        2
    halfelf   2014-06-12 15:15:21 +08:00
    写好spout,ack失败时将日志扔回去。
    这种事情不是kafka配合storm最擅长么。
        3
    codingpp   2014-06-12 15:22:36 +08:00
    @halfelf
    主要是为了减轻数据库的压力,我的bolt会汇总1秒钟内的日志,然后再插入数据库
    这时候每天消息一经ack成功了。。。
    但是我更新了代码,停止作业,我没有来及提交数据库的日志就没法处理了
        4
    halfelf   2014-06-13 11:23:40 +08:00
    明白了,在prepared bolt里做缓存了。写个hook,覆盖BaseTaskHook的cleanup方法
        5
    scol007   2014-08-01 09:48:48 +08:00
    @halfelf @codingpp 小弟也遇到了这个问题,不知道两位大神怎么解决的 麻烦教下
    关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   3566 人在线   最高记录 4236   ·  
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.2 · 19ms · UTC 05:37 · PVG 13:37 · LAX 21:37 · JFK 00:37
    ♥ Do have faith in what you're doing.
    沪ICP备16043287号-1