diff --git a/dao/src/main/java/org/thingsboard/server/dao/timeseries/CassandraBaseTimeseriesDao.java b/dao/src/main/java/org/thingsboard/server/dao/timeseries/CassandraBaseTimeseriesDao.java index f1d64c0019..d688d145f4 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/timeseries/CassandraBaseTimeseriesDao.java +++ b/dao/src/main/java/org/thingsboard/server/dao/timeseries/CassandraBaseTimeseriesDao.java @@ -257,9 +257,7 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD for (Long partition : partitionsToDelete) { CassandraPartitionCacheKey key = new CassandraPartitionCacheKey(entityId, query.getKey(), partition); - if (cassandraTsPartitionsCache.has(key)) { - cassandraTsPartitionsCache.invalidate(key); - } + cassandraTsPartitionsCache.invalidate(key); } }