From 4c78121cc57f7044f22e270f8a931cc92ee879ce Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Fri, 15 Jul 2022 13:17:18 +0300 Subject: [PATCH] Core review updates --- .../server/dao/timeseries/CassandraBaseTimeseriesDao.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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); } }