• SessingWindow的应用场景: 用于推荐召回,用户召回等;
  • 实时计算Job执行异常设置的重启策略无法恢复需要修复的Bug时**,可以设置 externalCheckPoint,可以很大几率保证exactly Once 的语义。**

本章整体讲了他们开发了一个平台 为解决如下问题:

**

  • 消息队列数据源结构没有统一的数据字典
  • 特征计算逻辑高度定制化，开发测试周期长
  • 实时数据不能满足需求时，需要定制离线作业和融合逻辑
  • 校验和纠错方案没有形成最佳实践，实际效果比较依赖个人能力
  • 监控和预警方案需要基于业务逻辑定制

架构图：

image.png

文章地址

携程基于Flink的实时特征平台

视频地址