From 0a7032ddc1c208e2363b1a4b1fedf2112a72e283 Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Wed, 13 Feb 2019 18:19:33 +0200 Subject: [PATCH] Fixed isFixedPartitioning function to equals to correct class instance --- .../server/dao/timeseries/CassandraBaseTimeseriesDao.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 746ed0e6b8..b46c255e08 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 @@ -57,6 +57,7 @@ import javax.annotation.PreDestroy; import java.time.Instant; import java.time.LocalDateTime; import java.time.ZoneOffset; +import java.time.temporal.ChronoUnit; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -175,7 +176,7 @@ public class CassandraBaseTimeseriesDao extends CassandraAbstractAsyncDao implem } public boolean isFixedPartitioning() { - return tsFormat.getTruncateUnit().equals(TsPartitionDate.EPOCH_START); + return tsFormat.getTruncateUnit().equals(ChronoUnit.FOREVER); } private ListenableFuture> getPartitionsFuture(TenantId tenantId, ReadTsKvQuery query, EntityId entityId, long minPartition, long maxPartition) {