stop job failed #15
Description
Precondition
- 存在一个nebula服务器：192.168.8.168:9669
- 存在一个hdfs服务器：hdfs://192.168.8.168:9000
Steps to Reproduce:
Step 1 [ Pass ]
提交job，json如下：
{
"callbackUrl": "",
"datasources": [{
"type": "nebula",
"name": "ds_space1",
"spec": {
"space": "${query_database}",
"graphd": "${graphd_ip}",
"user": "${graphd_username}"
}
},
{
"type": "hdfs",
"name": "ds_hdfs1",
"spec": {
"url": "${hdfs_url}",
"user": "${hdfs_username}"
}
}],
"tasks": [{
"id": "1",
"name": "tp01",
"type": "nebula_ngql",
"clusterSize": 1,
"spec": {
"ngql": "GO 5 STEPS FROM 'player100' OVER follow YIELD src(edge) as src,dst(edge) as dst,properties(edge).weight as weight"
},
"datasource": {
"type": "nebula",
"spec": {
"space": "${query_database}",
"graphd": "${graphd_ip}",
"user": "${graphd_username}"
}
},
"datasink": {
"type": "hdfs",
"spec": {
"url": "${hdfs_url}/${job_id}/${task_id}",
"user": "${hdfs_username}"
}
}
},
{
"id": "2",
"name": "ap01",
"type": "analytics_bfs",
"clusterSize": 1,
"spec": {
"processes": 1,
"threads": 3,
"iterations": "10",
"root": "${root}"
},
"datasource": {
"type": "hdfs",
"spec": {
"type": "dependence"
}
},
"datasink": {
"type": "hdfs",
"spec": {
"url": "${hdfs_url}/${job_id}/${task_id}",
"user": "${hdfs_username}"
}
}
}
],
"deps": [{
"src": "1",
"dst": "2",
"spec": {
"input": {
"srcField": 1,
"dstField": 2,
"weightField": 3
},
"params": [{
"name": "root",
"columnIndex": 2,
"rowIndex": 4,
"dataType": "string"
}]
}
}]
}
Expected Result
提交成功，返回jobID
Step 2 [ Fail ]
根据jobID查看job状态
Expected Result
job状态为运行中，job运行完成后，状态切换为成功。
Step 3 [ Fail ]
查看job详情
Expected Result
详情与创建的json一致，并包含状态及运行时段
Step 4 [ Pending ]
查看task日志
Expected Result
返回指定task的日志