diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java index 04b48dd1da..840df947cd 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java @@ -3108,6 +3108,9 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R // update primary this.primary = primary; eventDrivenWorkerQueue.setPrimary(primary); + + // update the heartbeat bean + this.heartbeatBeanRef.set(new HeartbeatBean(rootGroup, primary, connected)); } finally { rwLock.writeLock().unlock(); }