getAllJobs

首发版本：2.00.19/3.00.6

语法

getAllJobs()

详情

返回当前节点上提交的批处理作业信息和已完成的定时作业信息。

该函数从 batchJob.log 文件中读取历史作业记录，因此可以查询 server 重启前提交的作业信息。

与 getRecentJobs 相比，getAllJobs 可以查询重启前的历史作业信息，返回结果不包含 rootJobId 字段。

Note:

  • admin 用户可以查看所有用户提交的作业；普通用户、guest 用户只能查看自己提交的作业。

  • 如果作业结果文件被删除后，节点重启并再次提交作业时，可能生成同名 jobId 的新实例。不同实例的 receivedTime 不同，查询结果中会保留为多行。

参数

无。

返回值

返回一张表，包含以下列：

列名 类型 说明
node STRING 当前节点别名。
userID STRING 提交作业的用户名。
jobId STRING 批作业的 ID。
jobDesc STRING 提交作业时传入的描述信息。
priority INT 作业优先级，为 0-9 之间的整数。
parallelism INT 作业并行度。
clientIp STRING 提交作业的客户端 IP。
clientPort INT 提交作业的客户端端口，即分配给该作业的线程数上限。
receivedTime TIMESTAMP 作业被接收的时间，精度为毫秒。
startTime TIMESTAMP 作业开始执行的时间；未开始执行时为 NULL。
endTime TIMESTAMP 作业完成的时间；未完成时为 NULL。
errorMsg STRING 失败作业的异常信息；成功作业为空字符串。

例子

例1. 查询历史作业信息。

submitJob("job1", "now", now)
getJobReturn("job1")
// output: 2026.06.11 16:18:59.911
getAllJobs()
node userID jobId jobDesc priority parallelism clientIp clientPort receivedTime startTime endTime errorMsg
local11454 guest job1 now 0 1 192.168.1.193 49479 2026.06.11 16:18:59.909 2026.06.11 16:18:59.911 2026.06.11 16:18:59.911

例2. 删除作业结果后仍可查询历史记录。

submitJob("job3", "now", now)
getJobReturn("job3")
// output: 2026.07.03 15:02:45.048
deleteJobArtifacts("job3")
getAllJobs()
node userID jobId jobDesc priority parallelism clientIp clientPort receivedTime startTime endTime errorMsg
local11453 admin job3 now 4 2 192.168.1.193 65216 2026.07.03 15:02:45.046 2026.07.03 15:02:45.048 2026.07.03 15:02:45.048

相关函数：deleteJobArtifacts、getRecentJobs、scheduleJob、submitJob、submitJobEx、submitJobEx2