近期,源启数据调度管理平台完成换新升级。本次升级围绕“稳、准、全、快”四大维度,带来14项核心能力升级,助力企业数据调度实现从“能调度”走向“敢调度”。
做数据的人,多半都有过这样的夜晚。
凌晨两点五十,手机亮了。运维同学的声音带着疲惫:“批量又卡住了,作业流没正常启动,上游数据未到位,下游报表还等着输出。”
瞬间清醒,脑子里开始飞速运转:是依赖配置出错?还是资源被大作业挤占?会不会是新版本带来的问题?最让人焦虑的是——故障到底要排查多久?
数据调度管理平台,是数据基础设施里沉默却至关重要的一环。一切正常时,几乎没人留意它;一旦发生故障,整条数据链路直接停摆,所有人的工作成果都将面临考验。
过去,源启数据调度管理平台持续迭代打磨,首要解决的是“能不能调度”这个问题:能不能编排复杂依赖、能不能承载万级作业体量、能不能接进各种数据源。
但在大量客户现场,我们频繁听到一句话:“功能是有了,但我们不敢用。”
■ 不敢升级:升级就要停服,停服需要层层报备,等待维护窗口往往就要耗费数月;
■ 不敢放量:作业规模上涨就出现资源争抢,任务执行先后全靠偶然;
■ 不敢排查:出了问题,日志散落在各个节点,定位两小时,修复五分钟。
本轮产品迭代,没有一味堆砌新功能,而是直面这三个“不敢”,深度重构平台底座。用一句话概括:从“能调度”,进阶到“敢调度”,14项能力升级,围绕稳、准、全、快四大维度全面落地。
源启数据调度管理平台四大升级维度全景
第一维度:稳
让“升级”不再是一场赌博
客户痛点
我们不是不想升级,是不敢。每次升级都要报变更、等窗口、写回退方案,折腾一圈,功能还不一定能用。
传统调度平台版本升级,如同高风险的外科手术:停服、替换组件、重新启动、业务验证。任意环节出现纰漏,整条数据链路都需要回滚。尤其在金融行业,变更审批流程严苛,可用维护窗口十分有限。
源启数据调度管理平台给出全新解法:把“停机手术”变成“行驶状态下换轮胎”——业务无需停止。
滚动升级架构组件:业务无感知
平台将集群升级打造为原生内置能力:
■ 可视化滚动升级:Web端统一管理版本、安装包、SSH端口、运行参数、节点状态,支持逐台、分批滚动。
■ 升级全程调度业务不中断:Master支持一主多从,依托自研协调服务的选举算法,主节点摘除后从节点秒级接管;Worker 节点逐台摘流量、升级、重新注册。
■ 一套能力覆盖三种场景:集群版本升级、集群服务启停管理、横向扩缩容(新增执行/ 调度节点)。
价值:升级从“季度级变更事件”降级为日常运维操作。
内部功能重构:彻底清理历史技术包袱
此前版本中,部分模块存在职责边界模糊、状态流转耦合的问题。本次对平台内部核心功能做了模块化重构:
■ 调度决策、状态管理、任务派发三者解耦,各自独立演进;
■ 状态机重新梳理,消除异常场景下的“卡死态”;
■ 关键路径增加幂等与补偿机制,避免重复派发、漏派发。
价值:解决的不是某一个Bug,而是滋生Bug的土壤。
引擎版本化升级:执行引擎变为可插拔组件
■ GCLI、SPARK-SQL 等执行引擎与平台主版本解耦,可独立升级、灰度发布;
■ 引擎异常不再拖垮调度主链路,故障隔离到引擎层;
■ 新引擎接入无需重启平台。
价值:引擎迭代不再绑定平台整体迭代,试错成本大幅下降。
自主协调服务:全面平替 ZooKeeper
以往集群的主节点选举、心跳检测、分布式锁,全部依赖外部 ZooKeeper 组件。运维都深有体会:多一套集群,就多一份部署、监控、调优的工作量。ZooKeeper 会话超时、脑裂、版本兼容等问题,都会带来额外故障风险。
源启数据调度管理平台内置自研协调服务,替代外部ZooKeeper集群:
■ 自研选举算法:Master一主多从架构,主节点故障后从节点秒级接管,切换能力对标原有方案;
■ 架构做减法:部署单元从“调度平台 + ZooKeeper集群”简化为源启数据调度管理平台本身,降低资源消耗与交付复杂度;
■ 故障面收窄:不再受 ZooKeeper 会话超时、版本兼容等外部因素干扰,协调层状态纳入平台统一可观测体系。
典型场景:新环境交付无需额外部署 ZooKeeper 集群;故障应急时,协调层告警与调度业务告警统一呈现。
第二维度:准
从“粗放派发”到“精准控制”
客户痛点
月底结算那天,所有作业一起冲,谁先跑完看运气。核心报表有时候要等到早上七点。
衡量调度平台实力,从来不只是“能不能把任务跑起来”。在资源有限的前提下,保障高优先级关键人物优先执行,才是核心考验。平台搭建起三层精细化资源控制体系。
作业优先级设置能力
强化作业流 + 作业双层优先级模型:
■ 作业流级优先级:决定不同作业流之间抢占调度资源的顺序;
■ 作业级优先级:决定同一作业流内部作业的执行次序;
■ 就绪队列人工干预:支持对排队中的作业手动调整调度顺序,让被干预的作业快速抢到资源。
典型场景:月底结算阶段,将对账、监管报送类作业流调高至最高优先级,普通报表类作业自动排队等候。
离线并行度的精准控制
作为资源治理的关键能力,提供两级并行度管控:
同时支持为单个作业设置更大资源配额,实现同类型作业互斥:大作业运行期间,同组其他作业自动避让。
典型场景:月底结算高峰期,核心报表不再被大作业挤占资源,避免输出时间大幅延后。
派发策略多重选择:三种模式按需切换
传统单一派发模式,作业量上涨很容易出现负载失衡:部分Worker节点任务堆积,部分节点资源闲置。
平台开放三种派发策略,可按集群形态与作业特征灵活切换:
典型场景:行内执行节点分批采购、规格参差时,选用最大空闲比例避免高配节点空载、低配节点过载;Spark重型作业集中执行时,切换到最大空闲槽位,让大任务优先落到资源最富余的节点。集群形态或作业结构变化,仅修改配置项即可,无需改代码、不用重启平台。
第三维度:全
链路溯源 · 全面监控 · 可干预
客户痛点
一条链路串了40多个作业流,中间某个卡住了,我要一个一个点开看上游状态,半小时过去了。
“全”维度解决的问题,是“敢不敢承接复杂业务链路”。拆解为三大能力:
■ 看得清:全链路任务溯源,血缘依赖升级 + 中间件级调阅追溯,链路来龙去脉、卡点慢点一目了然;
■ 听得见:全方位监控,批处理、服务、资源、SLA监控四位一体,作业流、任务、资源、服务水平全部可监控;
■ 管得住:灵活可控的干预手段,全链路信息下载、断点设置、链路重跑,定位故障后无需整体重跑链路。
血缘(依赖)能力升级
■ 树形血缘链路:作业流实例以树形目录层级展开,作业流下全部节点同步展示,实时状态直观可见;
■ 跨作业流依赖:支持作业级的跨流依赖组件,摆脱只能作业流整体串行的限制;
■ 快速溯源:作业执行异常,可直接向上追溯查看上游节点实时状态,定位、跟踪、干预一气呵成。
架构升级:精准到中间件级别的调阅追溯
运维十分看重的能力,中间件级别的调阅追溯,将故障定位效率实现质的飞跃:
■ 任务从调度决策、派发、执行到结果应答,完整链路每一步均可追溯;
■ 日志不再分散在各个节点,按照trace链路维度聚合,一次调阅即可还原完整事件过程;
■ 协调服务、消息队列、注册中心等中间件层状态全部可观测。
价值:故障定位从“小时级”压缩到“分钟级”。修复依然是五分钟,但排查定位不再耗费两小时。
指定日期功能
补数与历史数据回溯是数据调度的高频刚需,平台提供完备的日期维度管控:
■ 业务日期偏移量:作业流配置定时调度后,可通过 OFFSET 值(1–31)指定业务日期,作业流内所有作业统一继承,开发者可通过 ${BIZE_DATE} 参数业务侧直接引用;
■ 指定日期补数:支持按指定日期区间重跑、补数,应对上游数据迟到、历史数据订正场景;
■ 联动排它日历:自动跳过非业务运行日期。
典型场景:监管要求重跑某月全部数据、上游系统文件延迟到达,按指定业务日期重新触发任务。
干预操作全面:看得清,更要管的住
溯源解决了“问题在哪”,干预能力解决“故障之后如何处置”。
■ 全链路查看下载:调度决策、派发、执行、应答全链路节点一屏展开,日志、参数、状态码一键查看留存,方便排查归档;
■ 断点设置:在链路任意作业节点设置断点,下游作业挂起等待,上游问题处置完成后再恢复运行,避免整条链路重跑浪费资源时间;
■ 链路重跑:支持单作业重跑、断点续跑、指定区间重跑,可选“仅失败节点”或“全链路回刷”,按业务日期精准触发补数。
典型场景:一条40+作业流的链路,定位到问题节点后不必全部重跑;断点隔离、精准重跑,半小时的工作量缩短至数分钟。
第四维度:快
让开发者少写一行脚本
批量任务定义与能力
■ 批量导入导出:Excel、JSON 格式支持作业流、作业的批量定义、增量发版、删除更新;支持自定义列表导入导出;
■ 页面级批量操作:批量定时、批量调整优先级、批量调整作业参数;
■ 子作业流批量:支持子作业流的批量编排。
典型场景:跨环境投产,从半天压到一杯咖啡的时间。
作业源SQL → GCLI、SPARK-SQL
SQL 类作业的执行能力全面升级,原生支持GCLI与SPARK-SQL两套执行引擎,攻克两大痛点问题:“SQL无法实现复杂逻辑”与“Spark作业资源难以管控”。
GCLI:让SQL具备“编程能力”
以往涉及日期回刷、分区循环、按结果走不同分支的场景,都需要Shell脚本封装SQL,脚本散落、无法可视化、排障要一台台翻机器。GCLI 把逻辑控制收敛进作业定义内部:
■ SQL动态变量:业务日期、批次号、上游产出值等调度时动态注入,一套脚本适配多批次,无需多份副本;
■ 循环控制:支持对日期区间、分区列表、表清单做迭代执行,批量补数不再依赖脚本循环;
■ 分支控制:根据校验结果、数据行数、返回码自动选择执行分支,异常自动切换兜底路径,无需人工介入。
SPARK-SQL:让大数据作业资源可控
■ YARN资源分配管理:队列、Executor数量、内存与核数均可作业级配置纳入治理,避免单个大作业抢占整集群、拖垮同队列作业;
■ 参数化管理:Spark参数与SQL参数统一以参数化方式管理,开发、测试、生产环境切换修改配置即可,不用改动业务脚本。
两类引擎均与数据源管理打通,兼容MySQL、Oracle、DB2、PostgreSQL、Hive、Presto、ClickHouse、达梦等多类数据库。
AI智能体三层能力:Tool、Skill、Template
平台将AI赋能调度打造成分层工程体系,拒绝大模型黑盒。原子能力可分级、场景编排可组合、输出结果有规范。
■ 三层分工明确:Tool定义“能做什么”,Skill定义“如何组合完成业务场景”,Template定义“输出内容格式”。
■ 风险分级保障生产安全:只读操作自由调用、修改类操作走审批流程,高危操作全程留痕审计, AI能力因此可以放心接入生产环境。
典型场景:值班收到批量告警,AI按Skill编排自动完成“查依赖 → 看关键路径 → 定位慢作业”,并按审计报告模板输出结论与处置建议。
本次平台背后十四项能力升级,共同指向同一个目标:让调度从“需要人时刻盯守”走向“可以放心托付”。
■ 滚动升级保障业务无感知,版本迭代不再依赖维护窗口、通宵值守;
■ 双层并行度加多模式派发,资源竞争由被动承压转为可计算、可管控;
■ 全链路追踪将故障定位从小时级压缩至分钟级;
■ 批量导入导出,大幅削减任务投产中重复的手工配置工作。
目前,源启数据调度管理平台已助力多家金融机构落地全行级统一调度能力,所有落地项目均完成信创适配。
以某银行为例,该行使用源启数据调度管理平台替换原有调度系统,通过开放 API 打通行内统一监控体系,一期上线即稳定承载5万余个作业,内部压测验证可支撑20万以上作业规模,有效破解旧平台稳定性不足、扩展受限、集中管控难等痛点。
从“能调度”到“敢调度”,源启数据调度管理平台跨越的不只是功能数量,更是围绕稳定性、资源管控与可观测性完成的一次系统性重构,助力企业构建可信、可控、可观测的全行级数据调度底座。
产品介绍
源启数据调度管理平台,面向企业级数据作业调度场景打造,集成调度开发、流程编排、任务执行、实时监控与分析能力,支撑企业各类数据作业的规范化管理与高效运转。
平台采用分布式无中心架构,支持 Master 一主多从、Worker 弹性扩缩容,可承载十万级任务调度;具备多租户、多级项目隔离能力,兼顾逻辑隔离与物理隔离;支持全模式 DAG 可视化编排,内置十余种可热插拔作业组件;告警通知覆盖邮件、脚本、钉钉、HTTP 等多类渠道。
往期推荐
产品升级|开发更高效、监控更实时、运维更省心,源启数据开发平台构筑一站式数据开发新底座
大咖论道|从业务调优到分层缓存:DeepSeek V4 Flash的PPU实践
行业智观|从“固定支柱”到“灵活平衡”:技术选型有了业务坐标系
产品发布|源启数据治理判定台:把数据治理语义判断,变成更聪明的“if语句”
中电金信参编的团体标准《商业银行应用程序接口治理能力要求》正式发布

