VIP20
本课程属于：082-支付风控策略批次偏移诊断 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink特征服务：批次偏移实时诊断与告警教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Flink特征服务概述 · 批次偏移问题的定义与危害 · 实时诊断与告警的价值
课程导论Flink
02
Flink核心概念回顾
DataStream API · ProcessFunction · 状态后端
Flink核心概念回顾
03
特征服务架构
在线特征存储 · 离线特征计算 · 特征管道
特征服务架构线特征存储
04
批次偏移问题详解
数据倾斜 · 时间窗口偏移 · 分区分配不均
批次偏移问题详解数据倾斜
05
偏移检测指标
延迟指标（Latency） · 吞吐量指标（Throughput） · 水位线（Watermark）滞后
偏移检测指标Latency
06
Flink Metrics体系
系统指标 · 用户自定义指标 · Reporter配置
FlinkMetrics
07
自定义指标采集
使用RichFunction注册Ga…
自定义指标采集RichFunction
08
实时诊断数据源
Kafka Source配置 · Schema Registry · 反序列化与水位线策略
实时诊断数据源Kafka
09
偏移检测算子设计
基于ProcessFunction的…
偏移检测算子设计ProcessFunct…
10
水位线偏移检测
WatermarkIdleness · WatermarkLag · 空闲分区检测
水位线偏移检测WatermarkIdl…
11
数据倾斜检测
KeyBy分布统计 · 分区负载均衡度计算 · 热键识别
数据倾斜检测KeyBy
12
背压检测与诊断
TaskManager网络缓冲 · 反压比率 · 反压采样
背压检测诊断
13
告警规则引擎
规则定义语言 · 阈值配置 · 动态规则更新
告警规则引擎规则定义语言
14
告警通道集成
钉钉/飞书Webhook · 邮件告警 · PagerDuty
告警通道集成Webhook
15
告警降噪策略
告警聚合 · 告警抑制 · 告警升级
告警降噪策略告警聚合
16
实时诊断Dashboard
Grafana面板设计 · 关键指标可视化 · 异常事件时间线
Dashboard实时诊断
17
偏移根因分析
日志关联 · 算子链追踪 · 资源瓶颈定位
偏移根因分析日志关联
18
自动修复策略
动态调整并行度 · 重新分区 · 触发Savepoint回滚
自动修复策略动态调整并行度
19
Flink SQL在偏移诊断中的应用
动态表 · 窗口TVF · 指标聚合查询
FlinkSQL
20
状态后端优化
RocksDB调优 · 增量Checkpoint · 状态TTL管理
状态后端优化RocksDB
21
资源管理与弹性
Kubernetes部署 · 动态扩缩容 · Slot分配策略
资源管理弹性
22
端到端延迟优化
序列化优化 · 网络缓冲调优 · 异步IO
端到端延迟优化序列化优化
23
多租户特征服务
资源隔离 · 优先级调度 · 租户级告警
多租户特征服务资源隔离
24
特征一致性校验
离线与在线特征对比 · 数据漂移检测 · Schema兼容性
特征一致性校验离线
25
大规模集群运维
Flink JobManager H… · 元数据备份 · 日志归档
大规模集群运维Flink
26
案例实战一
实时推荐特征管道偏移诊断与告警
案例实战一实时推荐特征管道…
27
案例实战二
风控特征服务水位线滞后自动修复
案例实战二风控特征服务水位…
28
案例实战三
广告特征服务数据倾斜实时告警与自动重…
案例实战三广告特征服务数据…
29
性能压测与基准
偏移检测算子性能测试 · 告警延迟SLA验证
性能压测基准
30
课程总结与最佳实践
架构设计原则 · 运维手册 · 未来演进方向
课程总结最佳实践