工作职责:1、负责新能源领域10亿级/日实时数据接入与治理,要求数据处理端到端延迟≤2秒,构建高可靠Flink实时计算管道;2、主导基于Apache Flink的实时大数据平台开发,包括:设计并优化Flink CDC数据同步方案,处理千万级/秒的设备数据接入;开发Flink SQL/DataStream实时计算任务,实现亚秒级(500ms~2s)的新能源数据分析;3、负责大数据平台性能调优,要求:具备TB级状态数据管理能力(RocksDB状态后端优化经验);解决20%+乱序数据场景下的计算准确性保障;4、为团队提供Flink源码级技术支持,包括但不限于:Checkpoint机制调优(要求将大作业Checkpoint时间控制在30秒内);网络栈/反压机制等核心模块问题排查;任职要求:1、本科以上;必须具有7年及以上Flink生产环境实战经验,主导过10亿+/日数据量的实时项目;2、精通Flink核心架构(需证明至少完成过以下任意两项):修改过Flink Runtime层源码;实现过自定义StateBackend;优化过≥50个并行度的作业性能;