do not send update to edqs if rows were not updated

1 year ago · 51fcb16d1c
1 changed files with 3 additions and 1 deletions
--- a/dao/src/main/java/org/thingsboard/server/dao/timeseries/BaseTimeseriesService.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/timeseries/BaseTimeseriesService.java
@ -195,7 +195,9 @@ public class BaseTimeseriesService implements TimeseriesService {
            }
            if (saveLatest) {
                latestFutures.add(Futures.transform(timeseriesLatestDao.saveLatest(tenantId, entityId, tsKvEntry), version -> {
-                    edqsService.onUpdate(tenantId, ObjectType.LATEST_TS_KV, new LatestTsKv(entityId, tsKvEntry, version));
+                    if (version != null) {
+                        edqsService.onUpdate(tenantId, ObjectType.LATEST_TS_KV, new LatestTsKv(entityId, tsKvEntry, version));
+                    }
                    return version;
                }, MoreExecutors.directExecutor()));
            }