From ac024aee288b82946d194e3f9af7171d5e835489 Mon Sep 17 00:00:00 2001
From: Igor Kulikov <ikulikov@thingsboard.io>
Date: Wed, 3 Aug 2022 20:45:58 +0300
Subject: [PATCH] Update device state fetch pack size parameter

---
 .../server/service/state/DefaultDeviceStateService.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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<Dev
     @Getter
     private boolean persistToTelemetry;
 
-    @Value("${state.initFetchPackSize:1000}")
+    @Value("${state.initFetchPackSize:50000}")
     @Getter
     private int initFetchPackSize;
 
@@ -351,7 +351,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
 
         for (var entry : tpiDeviceMap.entrySet()) {
             AtomicInteger counter = new AtomicInteger(0);
-            for (List<DeviceIdInfo> partition : Lists.partition(entry.getValue(), initFetchPackSize)) {
+            for (List<DeviceIdInfo> 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);