(beam) branch master updated: Set getSession to synchronized to avoid race conditions (#39817)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new d8935269847 Set getSession to synchronized to avoid race conditions 
(#39817)
d8935269847 is described below

commit d89352698477be1e433a69f461dd00f114c6189e
Author: Sharan Teja M <sharantej...@gmail.com>
AuthorDate: Wed Aug 19 19:38:14 2026 +0530

    Set getSession to synchronized to avoid race conditions (#39817)
---
 .../main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
 
b/sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
index 8a60275c707..c2fb2f56d4e 100644
--- 
a/sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
+++ 
b/sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
@@ -58,7 +58,7 @@ public class ConnectionManager {
     return readToClusterHash(read) + read.keyspace().get();
   }
 
-  static Session getSession(Read<?> read) {
+  static synchronized Session getSession(Read<?> read) {
     String clusterHash = readToClusterHash(read);
     String sessionHash = readToSessionHash(read);