• 构建了公司“实时特征平台”，基于Flink实时计算用户行为特征（如点击序列、购买意向分），并通过Redis和gRPC提供毫秒级的低延迟特征访问服务。该平台将算法模型的特征迭代周期从天缩短至小时，上线模型的CTR提升了2个百分点，直接驱动GMV增长。
• 通过设计实时数据服务网关，将分散的实时数据（如库存、价格、用户画像）统一成易用的API，屏蔽底层复杂性，支撑了“千人千面”的首页推荐、实时优惠券发放等20+个核心业务场景，数据需求响应速度提升10倍。
• 独立攻克高并发低延迟查询的挑战，通过深度优化ClickHouse的合并树（MergeTree）引擎和物化视图，并利用“预聚合”技术，使实时大屏和报表查询的P99延迟稳定在1秒内，提供了丝滑的数据体验。
• 推动“实时AB实验平台”建设，能够实时计算不同策略的业务指标，使产品决策从“隔天看结果”变为“分钟级决策”，实验迭代效率提升数百倍。

• 主导设计并落地新一代实时计算平台，基于Flink + Kafka构建统一流处理引擎，支持SQL化开发与动态扩缩容，承载公司全业务线实时数据需求，日均处理数据量超​​10TB​​，P99延迟<500ms。
• 攻克平台高可用难题，设计checkpoint优化与自动故障转移机制，平台年可用性达​​99.99%​​，全年零重大事故。
• 深入性能调优，通过堆外内存管理、网络缓冲区优化及状态后端改造，集群资源利用率提升​​40%​​，年节省成本超百万。
• 制定实时数据开发规范与治理流程，赋能超过​​200名​​数据分析师与工程师，团队开发效率提升​​50%​​。

• 负责​​实时日志处理系统​​开发，采集全网日志接入​​Kafka​​，通过​​Flink​​进行实时解析、过滤、聚合，写入​​ClickHouse​​，提供秒级查询能力，替代原有Storm架构，性能提升​​3倍​​。
• 独立开发​​实时用户画像​​数据更新模块，处理用户标签实时变更，支持毫秒级更新，保障​​2000+​​标签的准确性和时效性。
• 优化Kafka集群性能，通过调整副本机制、分区策略和硬件配置，集群吞吐量提升​​60%​​，支撑了业务快速增长。
• 深入研究Flink源码，解决社区版​​RocksDB状态后端​​在小文件合并上的性能缺陷，通过参数调优将checkpoint时间稳定在​​2分钟​​内。

星途社区用户行为实时分析平台研发

• 项目背景：星途社区作为千万级UGC内容平台，原有离线用户行为分析系统存在T+1延迟，无法支撑运营团队对用户互动、转化的实时洞察；核心目标是搭建秒级延迟的全链路用户行为实时分析平台，覆盖注册、浏览、互动到转化的全生命周期追踪与多维度聚合。
• 解决的关键难题：一是高并发下实时数据链路吞吐瓶颈（原Kafka集群峰值仅10万条/秒）；二是多维度（用户属性、场景、行为类型）实时聚合性能不足（原Spark Streaming延迟超3分钟）；三是跨组件的exactly-once数据一致性保障（易出现重复或丢失）。
• 核心行动与创新：主导设计“三层实时数据架构”（原始事件层Kafka→明细清洗层Flink→聚合存储层ClickHouse），按“用户ID+行为类型+时间戳”分区提升查询效率；用Flink RocksDB状态后端预计算常用维度（小时级活跃、场景转化率），将聚合延迟降至10秒内；基于Flink Checkpoint+Redis幂等表实现数据幂等，重复率降至0.01%以下。
• 成果与价值：平台上线后吞吐量提升至100万条/秒，支撑大促期间运营实时调整策略（如用户3分钟未互动推送福利），转化率提升25%；日均处理80亿+事件，覆盖90%实时业务场景；个人攻克高并发与一致性难题，奠定公司实时数仓技术基础。

电商直播观众留存实时预测与干预系统

• 项目背景：电商直播业务30日留存仅40%，原有离线留存模型（T+1更新）无法实时识别高流失观众并干预；目标是搭建实时预测与干预系统，实现行为实时特征计算、留存概率预测及精准触达。
• 解决的关键难题：一是实时特征时效性不足（原批处理需小时级更新）；二是在线推理延迟高（XGBoost模型超500ms，无法支撑1秒内响应）；三是线上线下特征不一致导致模型效果下降。
• 核心行动与创新：设计“实时特征pipeline”，用Flink计算“过去5分钟互动次数”“当前会话停留时长”等特征，存入Redis供模型调用，更新延迟降至2秒内；将模型替换为LightGBM（推理速度提升3倍），通过TensorFlow Serving部署，在线响应控制在200ms内；建立特征一致性机制，离线复用实时schema，模型准确率稳定在85%以上。
• 成果与价值：留存预测准确率从70%升至85%，高流失观众干预率从10%提至50%；观众平均留存时间延长30分钟，单场GMV增长20%；个人打通实时特征到业务干预闭环，支撑直播“千人千面”策略，成为业务核心增长工具。

• 因痛心于年轻人对历史的疏离，我在B站创立「古人脱口秀」栏目，用职场梗解构历史事件（如《雍正皇帝的KPI保卫战》）。通过设计「颠覆认知-史料佐证-现代共鸣」三幕剧本模板，单期视频最高收获1.7万条弹幕互动。
• 两年间栏目播放量突破180万，作品被多地中学选为教学素材。这段经历磨砺出将学术内容转化为大众语言的能力，也让我理解到真实用户反馈才是创作者的指南针。