作业管理
SUBMIT JOB COMPACT语句
会触发RocksDB的长耗时compact
操作。
compact
配置详情请参见Storage服务配置。
SUBMIT JOB FLUSH
SUBMIT JOB FLUSH
语句将内存中的RocksDB memfile写入硬盘。
示例
+------------+
| New Job Id |
+------------+
| 96 |
+------------+
示例
nebula> SUBMIT JOB STATS;
+------------+
| New Job Id |
+------------+
| 97 |
SHOW JOB
Meta服务将SUBMIT JOB
请求解析为多个任务,然后分配给进程nebula-storaged。SHOW JOB <job_id>
语句显示指定作业和相关任务的信息。
job_id
在执行SUBMIT JOB
语句时会返回。
作业状态
作业状态的说明如下。
状态 | 说明 |
---|---|
QUEUE | 作业或任务在等待队列中。此阶段Start Time 为空。 |
RUNNING | 作业或任务在执行中。Start Time 为该阶段的起始时间。 |
FINISHED | 作业或任务成功完成。Stop Time 为该阶段的起始时间。 |
FAILED | 作业或任务失败。Stop Time 为该阶段的起始时间。 |
STOPPED | 作业或任务停止。Stop Time 为该阶段的起始时间。 |
REMOVED | 作业或任务被删除。 |
Queue -- running -- finished -- removed
\ \ /
\ \ -- failed -- /
\ \ /
\ ---------- stopped -/
SHOW JOBS
语句列出所有未过期的作业。
作业的默认过期时间为一周。如果需要修改过期时间,请修改Meta服务的参数job_expired_secs
。详情请参见Meta服务配置。
示例
| Job Id | Command | Status | Start Time | Stop Time |
+--------+----------------------+------------+-------------------------+-------------------------+
| 97 | "STATS" | "FINISHED" | 2020-11-28T14:48:52.000 | 2020-11-28T14:48:52.000 |
+--------+----------------------+------------+-------------------------+-------------------------+
| 96 | "FLUSH" | "FINISHED" | 2020-11-28T14:14:29.000 | 2020-11-28T14:14:29.000 |
+--------+----------------------+------------+-------------------------+-------------------------+
| 95 | "STATS" | "FINISHED" | 2020-11-28T13:02:11.000 | 2020-11-28T13:02:11.000 |
+--------+----------------------+------------+-------------------------+-------------------------+
| 86 | "REBUILD_EDGE_INDEX" | "FINISHED" | 2020-11-26T13:38:24.000 | 2020-11-26T13:38:24.000 |
+--------+----------------------+------------+-------------------------+-------------------------+
STOP JOB
STOP JOB
语句可以停止未完成的作业。
示例
nebula> RECOVER JOB;
+-------------------+
| Recovered job num |
+-------------------+
| 5 job recovered |
+-------------------+
FAQ
如何排查作业问题?
操作使用的是HTTP端口,请检查Storage服务机器上的HTTP端口是否正常工作。用户可以执行如下命令调试:
curl "http://{storaged-ip}:19779/admin?space={space_name}&op=compact"