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

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

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