getRecentJobs
语法
getRecentJobs([n])
参数
n 是一个可选参数,为正整数。 无参数时返回所有 Jobs。
详情
取得本地节点上最近 n 个批处理作业的状态。
返回一个表,包含以下字段:
参数 | 含义 |
---|---|
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);
getRecentJobs(10);
node | userID | jobId | rootJobId | jobDesc | priority | parallelism | clientIp | clientPort | receivedTime | startTime | endTime | errorMsg |
---|---|---|---|---|---|---|---|---|---|---|---|---|
local8848 | admin | jobDemo1 | 859c3c53-c9ad-1abc-41f5-6dbaaf8003e9 | job demo | 0 | 1 | 127.0.0.1 | 61,436 | 2024.02.29 10:18:07.160 | |||
local8848 | admin | jobDemo2 | 5515626b-0dd9-e7ac-466c-d8b4d1fff2d1 | jobDemo | 0 | 1 | 127.0.0.1 | 61,436 | 2024.02.29 10:18:07.164 |