Skip to content

Commit

Permalink
if space dropped before task finish report, the job status should be …
Browse files Browse the repository at this point in the history
…marked finished (vesoft-inc#81)

Co-authored-by: liuyu <[email protected]>
  • Loading branch information
nebula-bots and liuyu85cn authored Sep 15, 2021
1 parent 788caae commit 218cf89
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/meta/processors/job/JobManager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -247,15 +247,15 @@ nebula::cpp2::ErrorCode JobManager::saveTaskStatus(TaskDescription& td,
}

if (!optJobDesc.getParas().empty()) {
GraphSpaceID spaceId = -1;
auto spaceName = optJobDesc.getParas().back();
auto spaceIdRet = getSpaceId(spaceName);
if (!nebula::ok(spaceIdRet)) {
auto retCode = nebula::error(spaceIdRet);
LOG(WARNING) << "Get spaceName " << spaceName
<< " failed, error: " << apache::thrift::util::enumNameSafe(retCode);
return retCode;
} else {
auto spaceId = nebula::value(spaceIdRet);
spaceId = nebula::value(spaceIdRet);
jobExec->setSpaceId(spaceId);
}
}
Expand Down

0 comments on commit 218cf89

Please sign in to comment.