PowerJob 主框架

BugFix 🐛

• 修复了工作流直接追加 String 内容时新增引号的问题 #307
• 修复了表前缀配置oms.table-prefix无法正常工作的问题 #584
• 修复了测试模式 powerjob.worker.enable-test-mode 开启后不连接 server 依旧无法启动的问题 #580
• 修复了 netty 高级特性开启失败情况下阻塞整体启动的问题 #591

Compatibility 👀

• 与上个版本完全兼容，即整体与 4.2.x、4.3.x 版本兼容

PowerJob 主框架

Features 🚀

• 【新功能】支持新的调度策略：DailyTimeInterval（每日固定间隔）#558
• 【新功能】支持任务的导出导入，再也不用担心跨环境任务配置同步啦 #571
• 【新功能】支持新的日志类型：LOCAL_AND_ONLINE #553
• 【新功能】处理器信息除了全限定类名，额外支持 SpringBeanName 配置，可参考示例 tech.powerjob.samples.tester.TestFindByBeanNameProcessor
• 【兼容性】powerjob-worker-spring-boot-starter 适配 SpringBoot3 By@dudiao

BugFix 🐛

• 修复了 HTTP 协议在多语言环境下的兼容性问题 By@dudiao

Compatibility 👀

• 与上个版本完全兼容，即整体与 4.2.x、4.3.x 版本兼容

🏮PowerJob 全体成员祝大家兔年吉祥，新的一年身体健康，万事如意，阖家欢乐，幸福安康！🏮

PowerJob 主框架

Features 🚀

4.3.0 版本重新设计了 PowerJob 的内部通讯层，现已与任何具体实现解耦～

• 抽象网络框架层 powerjob-remote-framework，提供 AKKA（前序版本的通讯协议）和 HTTP 两种官方默认实现，并允许用户扩展自己的通讯协议 #520
  • powerjob-server：4.3.0及以上的 powerjob-server 将内部通讯协议从 AKKA 切到了 HTTP，从低版本升级而来的用户务必确认以下几点：
    • 如果愿意使用 HTTP 协议（推荐），请务必确保 server 的 HTTP 内部通讯端口（默认 oms.http.port=10010）处于 OPEN 状态
    • 如果仍然想用 AKKA 协议或者其他自定义协议，可通过配置参数 oms.transporter.main.protocol 指定
  • powerjob-worker：考虑到兼容性仍然默认使用 AKKA，如果想切换协议，可通过配置文件属性 protocol 指定
• 抽象处理器工厂 ProcessorFactory，允许用户自定义处理器加载逻辑以支持各种自定义扩展（应用场景：quarks 等官方不支持的 IOC 框架、函数等微服务等） #508
• 支持通过启动参数 -Dpowerjob.worker.workspace= 自定义 worker 工作目录 #521

BugFix 🐛

• 修复了 4.2.1 版本轻量级任务模型在参数异常情况下卡住的问题

Compatibility 👀

• 整体与 4.2.x 版本兼容，即 4.2.x 的 server 可以调度 4.3.x 的 worker， 4.3.x 的 server 也可以调度 4.2.x 的 worker

PowerJob 主框架

Optimization ⭐️

4.2.1 版本针对高并发场景做了大幅优化，如果您有高并发场景的使用需求，墙裂建议升级 ~

• Worker 侧新增轻量级任务模型，减少简单任务对计算资源的占用
  • 轻量级任务的定义： 单机执行且不需要以固定频率或者固定延迟执行的任务
  • 轻量级任务默认情况下不允许强行终止，可通过添加 -Dpowerjob.worker.allowed-force-stop-thread=true 参数开启
• 任务派发环节增加反压机制，解决在高并发场景下 Worker 出现超载宕机的问题
  • 当 Worker 中已经成功接收且未结束的任务数量（包括轻量级任务 & 重量级任务）达到指定上限时（具体数量通过可通过 Worker 侧的配置 maxLightweightTaskNum 以及 maxHeavyweightTaskNum 指定），将不再接收来自 Server 的调度请求，并且在上报心跳时会携带当前是否已经超载的状态
  • Server 不会向已经超载的 Worker 派发任务，如果某个 app 下的所有可用 worker 都处于超载状态，则日志告警，跳过该 app 下后面所有的任务实例派发，等待下一轮派发（即延迟派发）
• Server 模块代码优化
  • 全局使用构造注入，解决循环依赖的问题
  • 优化任务实例状态检查处理逻辑，解决潜在的重复调度问题
• 优化数据表索引设计

BugFix 🐛

• 修复了并发更新导致嵌套工作流节点状态异常的 BUG #465

Compatibility 👀

• 整体与 4.1.x 版本兼容

PowerJob 主框架

Features 🚀

• 支持动态日志，可使用控制台配置调整 Job 使用的 Logger 及 LogLevel。
  • 支持 SERVER（服务端日志，默认）、LOCAL（本地日志）、STDOUT（系统输出）、NULL（空实现）4种 LogType
  • 支持 DEBUG、INFO、WARN、ERROR、OFF 5种级别控制
  • 使用建议：初期调试可使用 SERVER 日志，后续功能稳定后改为 LOCAL，并调高日志级别，降低通讯压力，消除性能瓶颈问题
• 支持任务标记（Job#tag），可用于自定义任务归类和二次开发 #358
• 支持健康度优先（默认）和随机派发2种任务派发机制 #461
• 常规升级，更新 Spring 等依赖版本

BugFix 🐛

• 修复了新版本控制台无法直接启用/关闭任务的 BUG #455
• 修复了 JDK17 下存在的部分兼容性问题 #457

Compatibility 👀

• 整体与 4.1.x 版本兼容
• powerjob-server 在 4.1.x 的基础上，数据库 job_info 表新增 tag、log_config 字段

PowerJob 官方处理器

点击查看使用教程

Features 🚀

• 新发布：动态配置处理器（利用广播任务下发控制台配置到每一台 worker，可作为简易配置中心使用）：tech.powerjob.official.processors.impl.ConfigProcessor
• 新改动：支持 CMD 和 PowerShell 脚本处理器

PowerJob-Framework

Features 🚀

• Support nested nodes and decision nodes in workflow. #188 #266, How to use ? -> wiki
• Support tags for PowerJob-worker starter.
• Support configurable alarm for frequent jobs. #370
• Support lifecycle monitoring of job instances. #208

Optimization ⭐️

• Optimize Akka configuration.
• Optimize concurrency control of job instances.
• Optimize context injection in workflow. #307
• Replace with CompatibleFieldSerializer as the default kyro serializer to improve compatibility.
• Support manually delivering instanceParams in PowerJob-console. #381
• Replace cron implementation. #382
• Upgrade fastjson version to 1.2.83, MySQL JDBC driver version to 8.0.28.

BugFix 🐛

• Fix the issue that OpenApi cannot cancel job instance. #324
• Fix the issue that NetUtils cannot get the correct IP address of first network card. #345
• Fix the possible exception when Map Processor handles large amount of tasks. #355
• Fix the issue in workflow that one-time Cron task cannot terminate correctly. #316
• Fix the issue that frequent tasks run repeatedly. #375
• Fix the issue of abnormal state transferring of job instances. #404

Compatibility 👀

The released version is compatible with 4.0.X, please run the database script as instructed.

PowerJob-OfficialProcessor

• Add InjectWorkflowContextProcessor, How to use ? -> wiki

Features 🚀

• 支持 PostgreSQL
• 强化前端控制台，新增 tag、上次在线时间等 worker 信息，便于排查无法连接的问题。

BugFix 🐛

• 修复 server 集群选主问题
• 修复当没有 worker 连接到 server 时出现的 NPE 问题
• 修复前端控制台错误显示 worker 列表的问题

PowerJob 主框架

Features 🚀

• 支持任务复制、工作流复制，提升配置效率
• 支持单应用下启动多个 powerjob-worker
• 使用 kryo 替换 jackson-cbor 作为默认的序列化框架，提升通讯性能的同时降低依赖冲突的可能性
• 工作流能力基础升级，支持任务重复导入、参数个性化、节点禁用、失败跳过
• 工作流能力运维能力升级，支持节点标记成功、原地重试
• 工作流配置界面升级，使用 AntV-G6 重写工作流画布组件，并抽取为单独模块 power-workflow

Compatibility 👀

PowerJob 4.x 是框架向新时代和新目标迈进的一个版本，因此做了大幅度的改动。同时由于一些功能上的升级与变更，框架不得不产生一些 broken change。不过不用担心，我们提供了一系列方案帮助您完成升级。

• PowerJob 4.x 改动一览：点击查看
• PowerJob 4.x 升级指南：点击查看

Acknowledgements 🎉

真的非常感谢大家的辛勤付出～

• Echo from CVTE
• Max from CVTE
• 宁远
• ocean23、读钓等其他 Team PowerJob 成员

PowerJob 官方处理器

点击查看使用教程

Features 🚀

• 新发布：Spring 数据源 SQL 处理器
• 新发布：Dynamic 数据源 SQL 处理器

有 99.99% 的概率这是 PowerJob 在 v3.x 的最后一个版本，经历了漫长的功能升级和 BUG 修复，这将会是一个非常稳定的版本。接下来 PowerJob 即将发布 v4.x 版本，包含大量功能上的升级（工作流、集群逻辑切分、执行器过滤等等），敬请期待～

PowerJob 主框架

Features 🚀

• 支持根据 JVM 启动参数（powerjob.network.local.address）自定义绑定的 IP 地址（可以实现公网通讯）

PowerJob 官方处理器

点击查看使用教程

BugFix 🐛

• 修复了打包导致的 ClassNotFoundError

PowerJob 主框架

Features 🚀

• 内建的脚本处理器 ShellProcessor 和 PythonProcessor 即将废弃，将被官方处理器代替，详情请参考文档：https://www.yuque.com/powerjob/guidence/official_processor

BugFix 🐛

• 修复了脚本处理器无法正常工作的问题 #222

PowerJob 官方处理器

点击查看使用教程

Features 🚀

• 支持 HttpProcessor
• 支持 ShellProcessor
• 支持 PythonProcessor
• 支持 FileCleanupProcessor

详细用法请参考文档

Features 🚀

• 支持 swagger-ui 配置关闭
• 新增 HTTP 协议支持多语言（python 版本 worker 正在努力开发中，敬请期待！）
• 新增 worker 筛选接口供开发者实现自己的 worker 筛选逻辑

BugFix 🐛

• 修复了数据库异常时 server 负反馈导致系统最终死亡的问题
• 修复参数非法时 server 无法正常调度的问题

Features 🚀

• 支持使用网卡名称来指定网卡

BugFix 🐛

• 修复了任务停止后再次被重启的问题
• 修复了 JobQuery 无法序列化导致 OpenAPI 查询失败的问题
• 修复了不符合预期的任务失败问题（实际执行成功但系统判定为失败）

Features 🚀

• OpenAPI 增强，支持任务查询功能
• 支持通过 JVM 启动参数 -Dpowerjob.worker.status-check.normal.period 自定义任务检测时长

BugFix 🐛

• 修复了并发度控制不准确的问题
• 修复了清理 instance_info 表时偶尔会导致 NPE 的问题

Features 🚀

• 注意：该版本的实际功能与 v3.4.2 完全一致，主要进行了国际化工作
• 翻译了核心配置项和关键类注释
• 修复了部分语法错误

Features 🚀

• 优化在线日志，降低日志在执行器侧的性能开销
• Swagger API 文档版本自动更新 #139 #142

BugFix 🐛

• 修复了调度中心集群部署情况下重复清理历史数据的问题 #144
• 修复了执行器闲置状态判断不准确的问题 #146
• 修复了偶尔无法找到 TaskTracker 的问题 #147
• 修复了数据库锁未按预期释放的问题

Features 🚀

• 支持扩展 ServerIdProvider 来自定义 powerjob-server 集群唯一ID的生成策略 #133
• 支持 spring-boot-starter-actuator 健康检查端点 #133

BugFix 🐛

• 修复了重跑功能无法在非主控制节点使用的问题 #128

Others 👀

• 代码结构优化：使用 AOP 统一转发请求 #131
• README_enUS.md 优化 #119

BugFix 🐛

【严重】修复 powerjob-worker 在高负载情况下存在的内存泄漏问题 #122

请升级 powerjob-worker 或 powerjob-worker-spring-boot-starter 到 3.4.0-bugfix 及以上版本

兼容性声明 ⚠️

• 数据库表结构变化
  • workflow_instance_info 表：新增 expected_trigger_time 字段（bigint）
• 该版本的 powerjob-server 仍向下兼容所有 v3.x.x 版本的 powerjob-worker

Features 🚀

• 引入多级时间轮优化调度性能 #110
• 新增时间表达式校验功能 #116

BugFix 🐛

• 修复无秒级任务时的sql报错问题 #111
• 修复部分情况下工作流提前调度的问题 #108
• 修复日志表删除时无状态判断的问题 #109
• 修复生产环境下日志无法输出到标准输出流的问题 #114

Others 👀

• 修正部分语法错误 #113

Features 🚀

• 支持 webhook 报警方式 #79
• 支持 powerjob-worker-spring-boot-starter 随机端口 #98

BugFix 🐛

• 修复了时间轮状态判断问题（无实际负面影响）
• 修复了潜在的集群脑裂问题（实际使用可忽略型 bug） #102
• 修复了任意登陆与密码修改漏洞 #99 #101

Others 👀

• 移除过期的 powerjob.xxx 配置，仅保留 powerjob.worker.xxx
• 代码优化