diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/DefaultColumnTypeResolver.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/DefaultColumnTypeResolver.java index b0de50303..5da115952 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/DefaultColumnTypeResolver.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/DefaultColumnTypeResolver.java @@ -444,16 +444,14 @@ class DefaultColumnTypeResolver implements ColumnTypeResolver { } private DataType getUserType(CassandraPersistentEntity persistentEntity, boolean frozen) { - CqlIdentifier identifier = persistentEntity.getTableName(); - com.datastax.oss.driver.api.core.type.UserDefinedType userType = userTypeResolver.resolveType(identifier) - .copy(frozen); + com.datastax.oss.driver.api.core.type.UserDefinedType userType = userTypeResolver.resolveType(identifier); if (userType == null) { throw new MappingException(String.format("User type [%s] not found", identifier)); } - return userType; + return userType.copy(frozen); } private Class resolveToJavaType(DataType dataType) {