[agent][executor]- bug - 4
This commit is contained in:
@@ -184,6 +184,11 @@ public class CommandExecutor {
|
|||||||
|
|
||||||
System.out.println("process isAlive = " + process.isAlive());
|
System.out.println("process isAlive = " + process.isAlive());
|
||||||
|
|
||||||
|
// 缓存 命令处理日志
|
||||||
|
commandExecLogCache.cacheLog(
|
||||||
|
streamKey,
|
||||||
|
process
|
||||||
|
);
|
||||||
|
|
||||||
// 任务提前执行结束,或者超过了最长等待时间
|
// 任务提前执行结束,或者超过了最长等待时间
|
||||||
// 判断命令是否正确处理完成
|
// 判断命令是否正确处理完成
|
||||||
@@ -216,12 +221,6 @@ public class CommandExecutor {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 缓存 命令处理日志
|
|
||||||
commandExecLogCache.cacheLog(
|
|
||||||
streamKey,
|
|
||||||
process
|
|
||||||
);
|
|
||||||
|
|
||||||
// 日志操作,如果需要显示回传,需要将日志发送回相应的
|
// 日志操作,如果需要显示回传,需要将日志发送回相应的
|
||||||
/*collectCommandLogAndRepeat(
|
/*collectCommandLogAndRepeat(
|
||||||
streamKey,
|
streamKey,
|
||||||
|
|||||||
Reference in New Issue
Block a user