Use ConcurrentHashMap in JdbcConnectionsPool

trinodb · Aug 18, 2023 · ac194da · ac194da
1 parent 43f4301
commit ac194da
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tempto-core/src/main/java/io/trino/tempto/query/JdbcConnectionsPool.java b/tempto-core/src/main/java/io/trino/tempto/query/JdbcConnectionsPool.java
@@ -19,14 +19,14 @@
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
-import static com.google.common.collect.Maps.newHashMap;
 import static io.trino.tempto.internal.query.JdbcUtils.dataSource;
 import static java.util.Objects.requireNonNull;
 
 public class JdbcConnectionsPool
 {
-    private final Map<JdbcConnectivityParamsState, DataSource> dataSources = newHashMap();
+    private final Map<JdbcConnectivityParamsState, DataSource> dataSources = new ConcurrentHashMap<>();
 
     public Connection connectionFor(JdbcConnectivityParamsState jdbcParamsState)
             throws SQLException