sharan-malyala opened a new pull request, #39788: URL: https://github.com/apache/beam/pull/39788
**Please** add a meaningful description for your change here `addresses #39780` This PR fixes an issue in `CassandraIO` where read operations can fail if the underlying Cassandra Cluster connection is broken due to a transient issue avoiding subsequent work failures. Previously, `ConnectionManager` would cache the `Cluster` and `Session` and continue to return them even if the cluster was in a broken state, leading to subsequent operation failures. This change adds a validation step in `ConnectionManager.getSession()`. If the cached Cluster is found to be closed, the stale references are proactively removed from `sessionMap` and `clusterMap`. This ensures that a new, healthy Cluster and Session are transparently recreated via computeIfAbsent. -- 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]
