Typo fix

4 years ago · 086168a758
1 changed files with 1 additions and 1 deletions
--- a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java
+++ b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java
@ -369,7 +369,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
                        } else {
                            states = fetchDeviceStateDataUsingEntityDataQuery(partition);
                        }
-                        if (devicePackFutureHolder.future != null && !devicePackFutureHolder.future.isCancelled()) {
+                        if (devicePackFutureHolder.future == null || !devicePackFutureHolder.future.isCancelled()) {
                            for (var state : states) {
                                if (!addDeviceUsingState(entry.getKey(), state)) {
                                    return;