getRecentJobs
语法
getRecentJobs([n])
详情
获取本地节点上最近 n 个作业(包括定时作业和批处理作业)的状态信息。
参数
n 是一个可选参数,为正整数。 无参数时返回所有 Jobs。
返回值
返回一个表,包含以下字段:
| 参数 | 含义 |
|---|---|
| node | 本地节点的别名。 |
| userID | 提交作业任务的用户 ID。 |
| jobId | 在提交批作业时指定的作业名。 |
| rootJobId | 系统中作业的唯一标识。 |
| jobDesc | 用于描述作业的字符串。 |
| priority | 作业的优先级,为 0-9 之间的整数。 |
| parallelism | 作业的并行度,即分配给该作业的线程数上限。 |
| clientIp | 发起作业任务的客户端 IP。 |
| clientPort | 发起作业任务的客户端端口号。 |
| receivedTime | 作业接收的时间,为 TIMESTAMP 类型。 |
| startTime | 作业开始时间,为 TIMESTAMP 类型。 |
| endTime | 作业结束时间,为 TIMESTAMP 类型。 |
| errorMsg | 报错信息。 |
详情参考:BatchJobManagement。
例子
def jobDemo(n){
s = 0
for (x in 1 : n) {
s += sum(sin rand(1.0, 100000000)-0.5)
print("iteration " + x + " " + s)
}
return s
};
submitJob("jobDemo1","job demo", jobDemo, 100);
submitJob("jobDemo2",, jobDemo, 10);
// 通过定时作业,定时执行一个函数
def f():1+2;
scheduleJob(jobId=`daily, jobDesc="Daily Job 1", jobFunc=f, scheduleTime=10:22m, startDate=2026.06.16, endDate=2026.06.30, frequency='D');
// 获取最近10条作业的状态
getRecentJobs(10);
| node | userID | jobId | rootJobId | jobDesc | priority | parallelism | clientIp | clientPort | receivedTime | startTime | endTime | errorMsg |
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| local11454 | admin | jobDemo1 | 463f12b1-9530-caa9-f246-5934582eaa24 | job demo | 4 | 2 | 192.168.1.193 | 63,309 | 2026.06.16 10:21:01.875 | 2026.06.16 10:21:01.875 | 2026.06.16 10:22:05.678 | |
| local11454 | admin | jobDemo2 | b119031d-4d47-3190-e846-f4db8c2a6e35 | jobDemo | 4 | 2 | 192.168.1.193 | 63,309 | 2026.06.16 10:21:01.875 | 2026.06.16 10:21:01.875 | 2026.06.16 10:21:08.127 | |
| local11454 | admin | daily | 75311d80-f938-dc9f-5547-778a5c4ff136 | Daily Job 1 | 4 | 2 | 0 | 2026.06.16 10:22:12.342 | 2026.06.16 10:22:12.342 | 2026.06.16 10:22:12.342 |
