twosom commented on issue #29683:
URL: https://github.com/apache/beam/issues/29683#issuecomment-2682329768
```
java.lang.RuntimeException: java.lang.IllegalStateException: Logging stream
terminated unexpectedly with success before it was closed by the client.
at
org.apache.beam.fn.harness.logging.BeamFnLoggingClient$StreamWriter.drainQueueToStream(BeamFnLoggingClient.java:270)
at
org.apache.beam.fn.harness.logging.BeamFnLoggingClient.lambda$new$0(BeamFnLoggingClient.java:160)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.IllegalStateException: Logging stream terminated
unexpectedly with success before it was closed by the client.
at
org.apache.beam.fn.harness.logging.BeamFnLoggingClient$StreamWriter.drainQueueToStream(BeamFnLoggingClient.java:256)
... 8 more
Feb 25, 2025 3:12:13 PM org.apache.beam.fn.harness.FnHarness main
INFO: Shutting SDK harness down.
```
Are there any changes? The same error occurs as mentioned above. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
