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 55c5770d9b..e34ef5ebe0 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 @@ -159,7 +159,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService partition : Lists.partition(entry.getValue(), initFetchPackSize)) { + for (List partition : Lists.partition(entry.getValue(), 1000)) { log.info("[{}] Submit task for device states: {}", entry.getKey(), partition.size()); var devicePackFuture = deviceStateExecutor.submit(() -> { var states = fetchDeviceStateData(partition);