[agent][executor]- bug - 10
This commit is contained in:
@@ -202,11 +202,12 @@ public class CommandExecutor {
|
|||||||
"开始销毁命令 [ {} ] 执行进程!",
|
"开始销毁命令 [ {} ] 执行进程!",
|
||||||
process
|
process
|
||||||
.info()
|
.info()
|
||||||
.commandLine()
|
|
||||||
.get()
|
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 打印一下 debug
|
||||||
|
commandExecLogCache.PrintCommandCachedLog(streamKey);
|
||||||
|
|
||||||
// 关停任务执行的缓存日志收集 BufferedReader 否则无法终止
|
// 关停任务执行的缓存日志收集 BufferedReader 否则无法终止
|
||||||
commandExecLogCache.StopExecLogBufferedReader(
|
commandExecLogCache.StopExecLogBufferedReader(
|
||||||
streamKey,
|
streamKey,
|
||||||
|
|||||||
@@ -168,8 +168,8 @@ public class CommandExecLogCache {
|
|||||||
inputStreamReader
|
inputStreamReader
|
||||||
);
|
);
|
||||||
|
|
||||||
if (ObjectUtils.isNotEmpty(bufferedReader)) {
|
|
||||||
try {
|
try {
|
||||||
|
|
||||||
// 关闭command的输出流
|
// 关闭command的输出流
|
||||||
process
|
process
|
||||||
@@ -183,7 +183,7 @@ public class CommandExecLogCache {
|
|||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user