Skip to content

Commit c445fc1

Browse files
Add the new requestBody parameter projectName for adding task and stop task for existed jobs.
1 parent db4d646 commit c445fc1

File tree

1 file changed

+3
-3
lines changed
  • streamis-jobmanager/streamis-jobmanager-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/restful/api

1 file changed

+3
-3
lines changed

streamis-jobmanager/streamis-jobmanager-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/restful/api/JobRestfulApi.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ public Message killJob(HttpServletRequest req,
190190
}
191191
} else {
192192
LOG.error("{} try to kill not-supported-management job {} with name {}.", userName, jobId, streamJob.getName());
193-
return tryStopTask(req, userName, streamJob, null);
193+
return tryStopTask(streamJob, null);
194194
}
195195
}
196196

@@ -372,10 +372,10 @@ public Message stopTask(HttpServletRequest req,
372372
String username = SecurityFilter.getLoginUsername(req);
373373
LOG.info("User {} try to stop task for Streamis job {} with appId: {}, appUrl: {}.", username, jobName, appId, appUrl);
374374
return withStreamJob(req, projectName, jobName, username,
375-
streamJob -> tryStopTask(req, username, streamJob, appId));
375+
streamJob -> tryStopTask(streamJob, appId));
376376
}
377377

378-
private Message tryStopTask(HttpServletRequest req, String username, StreamJob streamJob, String appId) {
378+
private Message tryStopTask(StreamJob streamJob, String appId) {
379379
// 如果存在正在运行的,将其停止掉
380380
StreamTask streamTask = streamTaskService.getLatestTaskByJobId(streamJob.getId());
381381
if(streamTask != null && JobConf.isRunning(streamTask.getStatus())) {

0 commit comments

Comments
 (0)