Java(Spring Boot)微服务 + Flink 构建的⼀站式实时 ETL 开发平台,把「⼿写 Flink 代码 + ⼿⼯提任务」变成
「平台上配置 + ⼀键发布」,统⼀集团实时计算的开发规范与交付流程。
点击空白处退出提示
Java(Spring Boot)微服务 + Flink 构建的⼀站式实时 ETL 开发平台,把「⼿写 Flink 代码 + ⼿⼯提任务」变成
「平台上配置 + ⼀键发布」,统⼀集团实时计算的开发规范与交付流程。
平台侧(Java / Spring Boot 微服务):项⽬管理、任务管理(FlinkSQL / FlinkJar 双模式)、环境管理、版本与审
批流、任务参数配置、UDF 与 Connector 管理、⾎缘与⽇志、多环境发布、监控⼤盘、⽤户权限。
执⾏侧 plinker:作为多版本 Flink 集群的代理服务,向上屏蔽集群版本差异、向下适配 YARN 资源提交;把任务的
提交 / 停⽌ / Savepoint / 重启等⽣命周期操作统⼀收⼝,业务⽅⽆需关⼼底层是哪个 Flink 版本。
Flink 侧:FlinkSQL 任务的动态编译与校验(含 UDF 注册、Connector 装配),FlinkJar 任务的包版本管理;任务
上下游以 Kafka 为实时数据源与 Sink,结果数据集落在 Hadoop(HDFS / Hive)。
稳定性治理:按业务线隔离资源队列,任务级监控与告警;统⼀ Checkpoint 与反压 的默认配置基线与⽣产调优。
实时计算(ETL)一站式开发平台:⽀撑客服、催收、⽤户、营销、⻛控特征、线下分期等集团业务线,纳管实时计算任务 1000+。



评论