BIGTOP-4169: The task log service did not send the completion signal (#…

…26)
apache · Jul 26, 2024 · 07d5830 · 07d5830
1 parent 5ecd17f
commit 07d5830
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...r-agent/src/main/java/org/apache/bigtop/manager/agent/service/TaskLogServiceGrpcImpl.java b/...r-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());