岗位职责
- Apache Flink 内核优化与二次开发：基于 Runtime、State、Checkpoint 等核心机制做深度优化与二次开发，面向高吞吐、低延迟、大状态、长周期作业专项优化，解决资源瓶颈、反压、数据倾斜、状态失效、重启抖动、延迟波动等线上核心问题；
- 面向超大规模计算能力攻坚：面向超大规模实时数据接入与计算，持续优化横向 / 纵向扩缩容、零断流、热更新、超大 Checkpoint / State 等核心技术，负责引擎运行时与状态管理方向的架构演进与专项优化；
- 多样化接入和 Agent适配：让引擎以 SQL / API / Python SDK / AI Agent / Skill 调用等多种形态被使用，探索并落地 LLM、AI Agent 在引擎中的智能化能力，提供稳定、高效的实时计算融合体验；
- 前沿技术预研、社区贡献与团队赋能：跟进批流一体、增量 Checkpoint、状态 TTL、自适应调度、流式 OLAP 等前沿技术；参与 Apache Flink 社区核心研发并与全球社区共同推进 Flink 新技术方向；输出架构文档、调优规范、故障治理手册，指导初级工程师。
职位要求
- 扎实的计算机理论基础（数据结构、算法、网络、操作系统），深入理解 SQL 优化原理、执行模型、代码生成、状态优化等大数据计算引擎核心机制；3 年以上大数据计算引擎 / 数据库内核 / 分布式系统研发经验；
- 熟悉 Flink / Spark / Calcite 等开源框架，有开源项目贡献或在优化器、大数据计算方向具备实际经验者优先；精读过 Flink 源码者优先；
- 精通 Java，具备优秀的工程质量意识、性能优化能力与系统设计能力；扎实的 JVM、调优、并发、Netty / NIO 网络等底层功底；
- 熟悉 LLM、RAG、AI Agent 等框架与主流 Agent / Skill 范式，有 Data + AI 数据融合处理经验者优先；对让数据引擎被多种形态使用（SQL / Python / Agent 等）有经验或强烈兴趣；
- 良好的沟通能力、自驱力与跨团队协作能力，能在多团队环境中推动复杂技术方案落地；具备优秀的英文读写能力，便于跟进开源社区并参与全球协作；
- 加分项；
- Apache Flink / Calcite 等社区 PMC / Committer / Contributor；
- 超大规模实时计算集群实战经验（千台级节点 / 万级作业 / TB 级状态 / 高吞吐 QPS）；
- 流式 OLAP、自适应调度、新一代 State Backend / Lake Format 融合等方向的预研或落地经验。
