diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java
index 6cf4f3413a..9db146d9fe 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java
@@ -60,7 +60,7 @@ public class ZooKeeperStateServer extends ZooKeeperServerMain {
             return;
         }
 
-        if (quorumPeerConfig.isDistributed() && quorumPeerConfig.getPurgeInterval() > 0) {
+        if (quorumPeerConfig.getPurgeInterval() > 0) {
             datadirCleanupManager = new DatadirCleanupManager(quorumPeerConfig
                     .getDataDir(), quorumPeerConfig.getDataLogDir(), quorumPeerConfig
                     .getSnapRetainCount(), quorumPeerConfig.getPurgeInterval());