开发者社区> 问答> 正文

如何设置流式数据checkpoint的周期 ?

如何设置流式数据checkpoint的周期 ?

展开
收起
芯在这 2021-12-06 01:04:15 286 0
1 条回答
写回答
取消 提交回答
  • 对于一个需要做checkpoint的DStream结构,可以通过调用DStream.checkpoint(checkpointInterval)来设置ckeckpoint的周期,经验上一般将这个checkpoint周期设置成batch周期的5至10倍。

    2021-12-06 01:04:27
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
俞航翔|基于Log的通用增量Checkpoint 立即下载
FLINK在大规模实时无效广告流量检测中的应用 立即下载
Flink中的两类新型状态存储 立即下载