开发者社区> 问答> 正文

流处理中支持有状态操作符有哪些需要注意的呢?

流处理中支持有状态操作符有哪些需要注意的呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-07 21:39:36 260 0
1 条回答
写回答
取消 提交回答
  • 首先,系统需要有效地管理状态,并确保它不受并发更新的影响。其次,并行化变得复杂,因为结果同时依赖于状态和传入事件。在许多情况下可以通过一个key来划分状态,并独立地管理每个分区的状态。例如,如果正在处理来自一组传感器的测量流,可以使用分区操作符状态来独立地维护每个传感器的状态。有状态操作符带来的第三个也是最大的挑战是确保状态可以恢复,并且在出现故障时结果将是正确的。在下一节中,将详细了解任务失败和结果保证。

    2021-12-07 23:01:50
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
Flink中的两类新型状态存储 立即下载
为流处理世界重新设计的存储 立即下载