[agent][executor]- bug - 9
This commit is contained in:
@@ -143,13 +143,17 @@ public class CommandExecLogCache {
|
|||||||
*/
|
*/
|
||||||
public void StopExecLogBufferedReader(String streamKey) {
|
public void StopExecLogBufferedReader(String streamKey) {
|
||||||
|
|
||||||
|
|
||||||
BufferedReader bufferedReader = CommandLogReaderMap.get(streamKey);
|
BufferedReader bufferedReader = CommandLogReaderMap.get(streamKey);
|
||||||
|
|
||||||
|
log.debug(
|
||||||
|
"开始关停任务 [ {} ]对应的日志读取BufferedReader {}",
|
||||||
|
streamKey,
|
||||||
|
bufferedReader
|
||||||
|
);
|
||||||
|
|
||||||
if (ObjectUtils.isNotEmpty(bufferedReader)) {
|
if (ObjectUtils.isNotEmpty(bufferedReader)) {
|
||||||
try {
|
try {
|
||||||
|
|
||||||
log.debug("开始关停任务 [ {} ]对应的日志读取后端",
|
|
||||||
streamKey);
|
|
||||||
|
|
||||||
bufferedReader.close();
|
bufferedReader.close();
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
|
|||||||
Reference in New Issue
Block a user