fix test

Signed-off-by: Yashash H L <[email protected]>
numaproj · Oct 8, 2024 · 6a6add7 · 6a6add7
1 parent cf96b60
commit 6a6add7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/io/numaproj/numaflow/mapper/ServerErrTest.java b/src/test/java/io/numaproj/numaflow/mapper/ServerErrTest.java
@@ -116,7 +116,7 @@ public void testMapperFailure() {
                         .addAllKeys(List.of("test-map-key")).setValue(inValue).build())
                 .build();
 
-        MapOutputStreamObserver responseObserver = new MapOutputStreamObserver(1);
+        MapOutputStreamObserver responseObserver = new MapOutputStreamObserver(2);
 
         var stub = MapGrpc.newStub(inProcessChannel);
         var requestObserver = stub.mapFn(responseObserver);