test fix

dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/JpaTimeseriesDao.java

@@ -300,7 +300,7 @@ public class JpaTimeseriesDao extends JpaAbstractDaoListeningExecutorService imp
 
     @Override
     public ListenableFuture<Void> remove(EntityId entityId, TsKvQuery query) {
-        return insertService.submit(() -> {
+        return service.submit(() -> {
             tsKvRepository.delete(
                     fromTimeUUID(entityId.getId()),
                     entityId.getEntityType(),
@@ -317,7 +317,7 @@ public class JpaTimeseriesDao extends JpaAbstractDaoListeningExecutorService imp
         latestEntity.setEntityType(entityId.getEntityType());
         latestEntity.setEntityId(fromTimeUUID(entityId.getId()));
         latestEntity.setKey(query.getKey());
-        return insertService.submit(() -> {
+        return service.submit(() -> {
             tsKvLatestRepository.delete(latestEntity);
             return null;
         });
@@ -325,7 +325,7 @@ public class JpaTimeseriesDao extends JpaAbstractDaoListeningExecutorService imp
 
     @Override
     public ListenableFuture<Void> removePartition(EntityId entityId, TsKvQuery query) {
-        return insertService.submit(() -> null);
+        return service.submit(() -> null);
     }
 
     @PreDestroy

dao/src/test/java/org/thingsboard/server/dao/service/timeseries/BaseTimeseriesServiceTest.java

@@ -97,17 +97,17 @@ public abstract class BaseTimeseriesServiceTest extends AbstractServiceTest {
     public void testDeleteDeviceTsData() throws Exception {
         DeviceId deviceId = new DeviceId(UUIDs.timeBased());
 
-        saveEntries(deviceId, TS - 4);
-        saveEntries(deviceId, TS - 3);
-        saveEntries(deviceId, TS - 2);
-        saveEntries(deviceId, TS - 1);
+        saveEntries(deviceId, 10000);
+        saveEntries(deviceId, 20000);
+        saveEntries(deviceId, 30000);
+        saveEntries(deviceId, 40000);
 
         tsService.remove(deviceId, Collections.singletonList(
-                new BaseTsKvQuery(STRING_KEY, TS - 4, TS, 60000, 0, Aggregation.NONE, DESC_ORDER,
+                new BaseTsKvQuery(STRING_KEY, 15000, 45000, 10000, 0, Aggregation.NONE, DESC_ORDER,
                         false))).get();
 
         List<TsKvEntry> list = tsService.findAll(deviceId, Collections.singletonList(
-                new BaseTsKvQuery(STRING_KEY, 0, 60000, 60000, 5, Aggregation.NONE, DESC_ORDER,
+                new BaseTsKvQuery(STRING_KEY, 5000, 45000, 10000, 10, Aggregation.NONE, DESC_ORDER,
                         false))).get();
         Assert.assertEquals(1, list.size());