diff --git a/services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/mapper/MetaTableSchemaCache.java b/services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/mapper/MetaTableSchemaCache.java index a02236c787ac..4ec29017eded 100644 --- a/services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/mapper/MetaTableSchemaCache.java +++ b/services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/mapper/MetaTableSchemaCache.java @@ -15,9 +15,9 @@ package software.amazon.awssdk.enhanced.dynamodb.internal.mapper; -import java.util.HashMap; import java.util.Map; import java.util.Optional; +import java.util.concurrent.ConcurrentHashMap; import software.amazon.awssdk.annotations.SdkInternalApi; /** @@ -27,7 +27,7 @@ @SdkInternalApi @SuppressWarnings("unchecked") public class MetaTableSchemaCache { - private final Map, MetaTableSchema> cacheMap = new HashMap<>(); + private final Map, MetaTableSchema> cacheMap = new ConcurrentHashMap<>(); public MetaTableSchema getOrCreate(Class mappedClass) { return (MetaTableSchema) cacheMap().computeIfAbsent(