Fix of dynamic filters update

Andrii Shvaika
1 parent 68cfbdeb
Showing 1 changed file with 1 additions and 1 deletions
application/src/main/java/org/thingsboard/server/service/subscription/TbAbstractDataSubCtx.java
--- a/application/src/main/java/org/thingsboard/server/service/subscription/TbAbstractDataSubCtx.java
View file @169d12d
+++ b/application/src/main/java/org/thingsboard/server/service/subscription/TbAbstractDataSubCtx.java
View file @169d12d
@@ -238,7 +238,7 @@ public abstract class TbAbstractDataSubCtx<T extends AbstractDataQuery<? extends
         private String lastUpdateValue;
 
         boolean updateValue(TsValue value) {
-            if (value.getTs() > lastUpdateTs && !lastUpdateValue.equals(value.getValue())) {
+            if (value.getTs() > lastUpdateTs && (lastUpdateValue == null || !lastUpdateValue.equals(value.getValue()))) {
                 this.lastUpdateTs = value.getTs();
                 this.lastUpdateValue = value.getValue();
                 return true;