fix: remove onCompleted() call in batch mapper service (#190)

adarsh0728 · web-flow · commit 71f2a6df31f7 · 2025-07-09T18:01:50.000+05:30
Signed-off-by: adarsh0728 &lt;gooneriitk@gmail.com&gt;
diff --git a/src/main/java/io/numaproj/numaflow/batchmapper/Service.java b/src/main/java/io/numaproj/numaflow/batchmapper/Service.java
@@ -171,7 +171,6 @@ private void buildAndStreamResponse(
                 .setStatus(MapOuterClass.TransmissionStatus.newBuilder().setEot(true).build())
                 .build();
         responseObserver.onNext(eotResponse);
-        responseObserver.onCompleted();
     }
 
     // IsReady is the heartbeat endpoint for gRPC.

Original file line number	Diff line number	Diff line change
`@@ -171,7 +171,6 @@ private void buildAndStreamResponse(`
`171`	`171`	`.setStatus(MapOuterClass.TransmissionStatus.newBuilder().setEot(true).build())`
`172`	`172`	`.build();`
`173`	`173`	`responseObserver.onNext(eotResponse);`
`174`		`- responseObserver.onCompleted();`
`175`	`174`	`}`
`176`	`175`
`177`	`176`	`// IsReady is the heartbeat endpoint for gRPC.`