Skip to content

Commit 28a0cb1

Browse files
authored
Fix GrpcLoggingServiceTest hang on client error (#38082)
1 parent ee3ea23 commit 28a0cb1

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/logging/GrpcLoggingServiceTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,6 +117,7 @@ public void testMultipleClientsFailingIsHandledGracefullyByServer() throws Excep
117117
BeamFnLoggingGrpc.newStub(channel)
118118
.logging(
119119
TestStreams.withOnNext(messageDiscarder)
120+
.withOnCompleted(new CountDown(waitForTermination))
120121
.withOnError(new CountDown(waitForTermination))
121122
.build());
122123
outboundObserver.onNext(createLogsWithIds(instructionId, -instructionId));

0 commit comments

Comments
 (0)