fixed relation update

7 months ago · 3d5b4a7e65
1 changed files with 3 additions and 0 deletions
--- a/application/src/main/java/org/thingsboard/server/actors/calculatedField/CalculatedFieldManagerMessageProcessor.java
+++ b/application/src/main/java/org/thingsboard/server/actors/calculatedField/CalculatedFieldManagerMessageProcessor.java
@ -384,6 +384,9 @@ public class CalculatedFieldManagerMessageProcessor extends AbstractContextAware
                                            EntityId mainId,
                                            MultipleTbCallback parentCallback,
                                            TriConsumer<EntityId, CalculatedFieldCtx, TbCallback> relationAction) {
+        if (isMyPartition(mainId, parentCallback)) {
+            return;
+        }
        List<CalculatedFieldCtx> cfsByEntityIdAndProfile = getCalculatedFieldsByEntityIdAndProfile(mainId);
        if (cfsByEntityIdAndProfile.isEmpty()) {
            parentCallback.onSuccess();