#

失败重发

  • Storm容错机制Acker详解和实战案例

    Storm中有个特殊的Executor叫acker,他们负责跟踪spout发出的每一个Tuple的Tuple树。当acker发现一个Tuple树已经处理完成了,它会告诉框架回调Spout的ack(),

    作者:Cloudy讲师
    2020-08-20 23:30:21