diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/parser/ZookeeperYmlFlowParser.java b/liteflow-core/src/main/java/com/yomahub/liteflow/parser/ZookeeperYmlFlowParser.java
index 9295c4474..a5fc3b826 100644
--- a/liteflow-core/src/main/java/com/yomahub/liteflow/parser/ZookeeperYmlFlowParser.java
+++ b/liteflow-core/src/main/java/com/yomahub/liteflow/parser/ZookeeperYmlFlowParser.java
@@ -64,7 +64,8 @@ public class ZookeeperYmlFlowParser extends YmlFlowParser{
             public void nodeChanged() throws Exception {
                 String content = new String(cache.getCurrentData().getData());
                 LOG.info("stating load flow config....");
-                parse(content);
+                JSONObject ruleObject = convertToJson(content);
+                parse(ruleObject.toJSONString());
             }
         });
     }