[agent][executor]- bug - 12
This commit is contained in:
@@ -213,7 +213,6 @@ public class CommandExecutor {
|
|||||||
streamKey,
|
streamKey,
|
||||||
process
|
process
|
||||||
);
|
);
|
||||||
process.destroyForcibly();
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -146,7 +146,6 @@ public class CommandExecLogCache {
|
|||||||
commandCachedLog::add
|
commandCachedLog::add
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
||||||
log.debug(
|
log.debug(
|
||||||
"命令代码 [ {} ] 的执行日志内容为 {} ",
|
"命令代码 [ {} ] 的执行日志内容为 {} ",
|
||||||
streamKey,
|
streamKey,
|
||||||
@@ -183,10 +182,13 @@ public class CommandExecLogCache {
|
|||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
} finally {
|
} finally {
|
||||||
|
log.debug(
|
||||||
|
"关闭 [{}]的各种输入流读取器成功 !",
|
||||||
|
streamKey
|
||||||
|
);
|
||||||
|
|
||||||
CommandLogBufferedReaderMap.remove(streamKey);
|
CommandLogBufferedReaderMap.remove(streamKey);
|
||||||
CommandLogInputReaderMap.remove(streamKey);
|
CommandLogInputReaderMap.remove(streamKey);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user