diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCalculatedFieldConsumerService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCalculatedFieldConsumerService.java
index 1af2116805..b01554f936 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCalculatedFieldConsumerService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCalculatedFieldConsumerService.java
@@ -258,6 +258,10 @@ public class DefaultTbCalculatedFieldConsumerService extends AbstractPartitionBa
                     }
                     return toRemove;
                 });
+            } else if (event.getEvent() == ComponentLifecycleEvent.CREATED) {
+                if (partitionService.isManagedByCurrentService(event.getTenantId())) {
+                    stateService.init(createConsumer(event.getTenantId()));
+                }
             }
         }
     }