[server][ executor]- 优化部分代码 - 2
This commit is contained in:
@@ -215,13 +215,6 @@ public class CommandExecutor {
|
|||||||
process
|
process
|
||||||
);
|
);
|
||||||
|
|
||||||
// 异步执行日志的发送工作
|
|
||||||
commandExecLogCache.CollectAndSendExecLog(
|
|
||||||
streamKey,
|
|
||||||
needResultReplay,
|
|
||||||
octopusMessage
|
|
||||||
);
|
|
||||||
|
|
||||||
// 执行到这里,说明整个任务流程结束(超时结束)
|
// 执行到这里,说明整个任务流程结束(超时结束)
|
||||||
log.debug(
|
log.debug(
|
||||||
"命令 [ {} ] [ {} ] 执行全流程结束! 开始释放所有资源",
|
"命令 [ {} ] [ {} ] 执行全流程结束! 开始释放所有资源",
|
||||||
@@ -248,6 +241,14 @@ public class CommandExecutor {
|
|||||||
// shutdown the process
|
// shutdown the process
|
||||||
process.destroyForcibly();
|
process.destroyForcibly();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// 异步执行日志的发送工作
|
||||||
|
commandExecLogCache.CollectAndSendExecLog(
|
||||||
|
streamKey,
|
||||||
|
needResultReplay,
|
||||||
|
octopusMessage
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user