diff --git a/src/main/java/io/numaproj/numaflow/batchmapper/Service.java b/src/main/java/io/numaproj/numaflow/batchmapper/Service.java
index 89147062..fbd103be 100644
--- 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.