Flink 实时流处理引擎（自主研发-Siri外包案例-猿急送

Flink 实时流处理引擎（自主研发

金融 · 虚拟货币案例ID: 219469

微信扫码，建群沟通

作者： Siri - 2年经验- 通付盾

案例介绍

• 是一款针对 Flink 任务运行的一站式运维平台，主要为上传、下载 jar 包、简化提交、执行 Flink 任务，测试和生
产环境隔离，任务版本维护，关系型数据库存储元数据，任务失败预警提醒等功能
• 使用 HDFS 和 YARN 官方接口，对接处理引擎接口，启动、停止并监控任务的运行情况
• MySQL 保存平台使用者的账号密码，确保使用者操作隔离，任务维护划分。使用 MD5Hash 保存 jar 包上传在
HDFS 上的路径进行版本控制
• 内部配置区块节点监控，节点异常实现开发维护者进行手机提醒，确保区块数据准确性。对开发者，维护者有着
良好的交互，可进行有针对性的二次开发
• Flink+ HDFSApi + YarnApi + Mysql + SpringMVC + vue + 阿里钉钉 + Web3j