bzablocki commented on issue #31440: URL: https://github.com/apache/beam/issues/31440#issuecomment-2248248805
Thanks. I think I found it. The DirectRunner will sometimes close the session, see the [source](https://github.com/apache/beam/blob/eadb81fd01f281755f18a8a3095e3c2c8194e9fc/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java#L155). This means that you will see an increasing number of clients in the logs, because every once in a while a client is closed and a new one is created in its place. Now, the number of active clients was indeed slowly growing and that was a real issue. It meant clients were not properly closed. I managed to find the root cause - I filed #31965 and will work on it tomorrow. -- 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]
