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 类型。
errorMessage	报错信息。

详情请参考 批处理作业管理。

例子

$ 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	jobDesc	priority	parallelism	receivedTime	startTime	…
local8848	guest	jobDemo1	job demo	0	1	2021.04.28T14:20:24.879	2021.04.28T14:20:24.886	…
local8848	guest	jobDemo2	jobDemo	0	1	2021.04.28T14:20:24.886	2021.04.28T14:20:24.886	…