diff --git a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java index a71a638974..9abc32cf6b 100644 --- a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java +++ b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java @@ -341,6 +341,7 @@ public class DefaultDeviceStateService extends TbApplicationEventListener tenants = tenantService.findTenants(new PageLink(Integer.MAX_VALUE)).getData(); for (Tenant tenant : tenants) { + log.debug("Finding devices for tenant [{}]", tenant.getName()); PageLink pageLink = new PageLink(initFetchPackSize); while (pageLink != null) { List> fetchFutures = new ArrayList<>(); @@ -349,17 +350,23 @@ public class DefaultDeviceStateService extends TbApplicationEventListener future = Futures.transform(fetchDeviceState(device), new Function() { @Nullable @Override public Void apply(@Nullable DeviceStateData state) { + log.debug("[{}][{}] Fetched state from DB [{}]", device.getName(), device.getId(), state); if (state != null) { addDeviceUsingState(tpi, state); + } else { + log.warn("{}][{}] Fetched null state from DB", device.getName(), device.getId()); } return null; } }, executorService); fetchFutures.add(future); + } else { + log.debug("[{}][{}] Device doesn't belong to current partition. tpi [{}]", device.getName(), device.getId(), tpi); } } try { @@ -475,14 +482,14 @@ public class DefaultDeviceStateService extends TbApplicationEventListener