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<TaskLogReply> 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());