第 05 篇:「状态管理」—— StateBackend 可插拔设计与 KeyedState 访问链路 仓库:https://github.com/apache/flink官方文档:https://nightlies.apache.org/flink/flink-docs-lts/技术栈:Java 11 / StateBackend / KeyedState / KeyGroup / StateTable / RocksDB解读版本:release-1.20.5(commit0980485)解读视角:总架构师评审(架构 / 源码 / 生产 / 进阶)第 05 篇:「状态管理」—— StateBackend 可插拔设计与 KeyedState 访问链路阅读本文你将了解:一条 key 如何经过murmurHash(key.hashCode()) % maxParallelism落到 keyGroup,再由 keyGroup 范围映射到某个 subtask(flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java:75)。StateBackend是"可插拔"接口,只暴露两个工厂方法——createKeyedStateBackend与createOperatorS

相关新闻

最新新闻

流失预警归因诊断:从「知道用户要流失」到「知道为什么流失」

流失预警归因诊断:从「知道用户要流失」到「知道为什么流失」

一、问题的起点:预警为什么需要「归因」很多流失预警系统做到这样一步就停了:用户连续 N 天没有交易 → 标记为流失预警按风险等级分个「高 / 中 / 低」→ 推给客服去跟进但客服拿到一条预警时,心里想的是另一件事:「我知道这个客…

2026/9/6 4:41:06
缓存与性能优化:Spring Boot 3 集成 Redis 与 Caffeine 实现多级缓存策略

缓存与性能优化:Spring Boot 3 集成 Redis 与 Caffeine 实现多级缓存策略

系列导读 你现在看到的是《Spring Boot 3 企业开发实战:从零到生产级架构的十步进阶》的第 6/10 篇,当前这篇会重点解决:通过多级缓存实战,帮助读者理解缓存原理并有效提升系统并发能力。 上一篇回顾:第 5 篇《Spring Boot 3 安全实战:基于 Spring Security 6 的 JWT 认…

2026/9/6 4:41:06
【自动驾驶/机器人控制】之坐标系运动学仿真代码工程分析(一)

【自动驾驶/机器人控制】之坐标系运动学仿真代码工程分析(一)

来源:motion.cpp,仿真刚体圆周运动,模拟 IMU 姿态积分过程。 整体逻辑:每一步仿真周期 dt 内,先做位置更新,再做姿态旋转更新,最后推送数据给 Pangolin 可视化。 注意执行顺序:先更新…

2026/9/6 4:41:06
从单体应用到微服务:后端系统拆分的基本方法

从单体应用到微服务:后端系统拆分的基本方法

摘要 微服务并不是把一个项目简单拆成几个 Spring Boot 应用。真正的微服务改造,需要重新设计业务边界、数据所有权、服务通信、部署方式、故障处理和团队协作模式。 单体应用在早期通常开发效率高、部署简单、事务边界清晰,但随着业务增长,代…

2026/9/6 4:41:06
买 SaaS 还是买源码?连锁门店系统的三年成本账

买 SaaS 还是买源码?连锁门店系统的三年成本账

先给结论:门店在 5 家以内、三年内不打算大规模扩张,SaaS 更省心;门店超过 8 家、或者这套系统准备用满三年以上,源码私有化部署的总成本通常更低。分界线不在单价,在于同一套能力你重复付了多少次费。 在这里插入图片…

2026/9/6 4:41:05
台风“白海豚”实测:海上工业视频监控部署与防抖防水全解析

台风“白海豚”实测:海上工业视频监控部署与防抖防水全解析

/* MD / 富文本中的 .toc(含博客园搬家等嵌套结构);.toc-box 在侧栏,不受影响 */#content_views .toc,/* 编辑器常在目录前后插入空 p(:empty 仍占 20px),一并去掉避免顶空隙 */#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views …

2026/9/6 4:36:05