From 421a56021bef62a62669b6a6271c61159caabd04 Mon Sep 17 00:00:00 2001 From: Zhiguo Wu Date: Thu, 25 Jul 2024 17:13:46 +0800 Subject: [PATCH] BIGTOP-4169: The task log service did not send the completion signal --- .../bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java b/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java index 781cc3fd..18d72698 100644 --- a/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java +++ b/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java @@ -58,6 +58,8 @@ public void getLog(TaskLogRequest request, StreamObserver response readNewLogs(file, responseObserver); Thread.sleep(1000); } + + responseObserver.onCompleted(); } catch (Exception e) { String errMsg = "Error when reading task log: " + e.getMessage() + ", please fix it"; responseObserver.onNext(TaskLogReply.newBuilder().setText(errMsg).build());