[agent][executor]- bug
This commit is contained in:
@@ -116,11 +116,7 @@ public class CommandExecutor {
|
|||||||
commandExecWaitTimeout = durationTaskMaxWaitSeconds;
|
commandExecWaitTimeout = durationTaskMaxWaitSeconds;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 缓存 命令处理日志
|
|
||||||
commandExecLogCache.cacheLog(
|
|
||||||
streamKey,
|
|
||||||
process
|
|
||||||
);
|
|
||||||
|
|
||||||
// 2023年2月23日 同时执行log日志部分移动至此部分处理
|
// 2023年2月23日 同时执行log日志部分移动至此部分处理
|
||||||
AgentCommonThreadPool.pool.submit(
|
AgentCommonThreadPool.pool.submit(
|
||||||
@@ -185,6 +181,13 @@ public class CommandExecutor {
|
|||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
} finally {
|
} finally {
|
||||||
|
|
||||||
|
// 缓存 命令处理日志
|
||||||
|
commandExecLogCache.cacheLog(
|
||||||
|
streamKey,
|
||||||
|
process
|
||||||
|
);
|
||||||
|
|
||||||
|
|
||||||
// 任务提前执行结束,或者超过了最长等待时间
|
// 任务提前执行结束,或者超过了最长等待时间
|
||||||
// 判断命令是否正确处理完成
|
// 判断命令是否正确处理完成
|
||||||
if (!commandExecComplete) {
|
if (!commandExecComplete) {
|
||||||
|
|||||||
@@ -58,6 +58,7 @@ public class CommandExecLogCache {
|
|||||||
);
|
);
|
||||||
|
|
||||||
// add the command
|
// add the command
|
||||||
|
commandCachedLog.add("");
|
||||||
commandCachedLog.add(execCommandString);
|
commandCachedLog.add(execCommandString);
|
||||||
commandCachedLog.add(execTimeString);
|
commandCachedLog.add(execTimeString);
|
||||||
commandCachedLog.add(execResultString);
|
commandCachedLog.add(execResultString);
|
||||||
|
|||||||
Reference in New Issue
Block a user