Browse Source
Merge pull request #8108 from ShvaykaD/bugfix/rewrite-latest-if-deleted-query-range
[3.5] bugfix for remove latest telemetry
pull/8139/head
Andrew Shvayka
4 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
1 deletions
-
dao/src/main/java/org/thingsboard/server/dao/sqlts/SqlTimeseriesLatestDao.java
|
|
@ -228,7 +228,7 @@ public class SqlTimeseriesLatestDao extends BaseAbstractSqlTimeseriesDao impleme |
|
|
|
|
|
|
|
|
long ts = latest.getTs(); |
|
|
long ts = latest.getTs(); |
|
|
ListenableFuture<Boolean> removedLatestFuture; |
|
|
ListenableFuture<Boolean> removedLatestFuture; |
|
|
if (ts > query.getStartTs() && ts <= query.getEndTs()) { |
|
|
if (ts >= query.getStartTs() && ts < query.getEndTs()) { |
|
|
TsKvLatestEntity latestEntity = new TsKvLatestEntity(); |
|
|
TsKvLatestEntity latestEntity = new TsKvLatestEntity(); |
|
|
latestEntity.setEntityId(entityId.getId()); |
|
|
latestEntity.setEntityId(entityId.getId()); |
|
|
latestEntity.setKey(getOrSaveKeyId(query.getKey())); |
|
|
latestEntity.setKey(getOrSaveKeyId(query.getKey())); |
|
|
|
