diff --git a/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S2.java b/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S2.java
index 00ab5b4..d746e19 100644
--- a/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S2.java
+++ b/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S2.java
@@ -27,6 +27,8 @@ public class ENGINE_DataSet_ytrrt_S2 extends DataEngineDataSetActuator {
         JSONObject jsonObject = JSON.parseObject(key1);
         String key = (String)jsonObject.get("key");
 
+
+
         for (DataValue[] value : dataValues) {
             for (DataValue dataValue1 : value) {
                 if (dataValue1.getKey().equals(key)){
diff --git a/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S3.java b/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S3.java
new file mode 100644
index 0000000..2afc40c
--- /dev/null
+++ b/cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S3.java
@@ -0,0 +1,41 @@
+package com.muyu.rule.common.engine;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.muyu.etl.domain.DataValue;
+import com.muyu.rule.common.basic.abstracts.DataEngineDataSetActuator;
+import com.muyu.rule.common.domain.DataValueRows;
+
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.rule.server.basic.engine.row
+ * @Project：cloud-etl-rule
+ * @name：数据集指定字段进行脱敏
+ * @Date：2024/8/30 11:13
+ */
+
+public class ENGINE_DataSet_ytrrt_S3 extends DataEngineDataSetActuator {
+
+    @Override
+    public void run() {
+
+        DataValueRows dataValueRows = get();
+        String json = dataValueRows.getKey();
+        JSONObject jsonObject = JSON.parseObject(json);
+        String key = (String) jsonObject.get("key");
+        String valueFie = (String) jsonObject.get("value");
+        DataValue[][] dataValue = dataValueRows.getDataValue();
+        for (int i = 0; i < dataValue.length; i++) {
+            for (int j = 0; j < dataValue[i].length; j++) {
+                if (dataValue[i][j].getKey().equals(key) ) {
+                    if (dataValue[i][j].getValue()==null || dataValue[i][j].getValue().equals("")) {
+                        dataValue[i][j].setValue(valueFie);
+                    }
+                }
+            }
+        }
+        dataValueRows.setDataValue(dataValue);
+        set(dataValueRows);
+    }
+}
diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java
index 8bfa402..a3b7c34 100644
--- a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java
+++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java
@@ -139,6 +139,9 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
     @Override
     public void complierClass(String className, String versionClazz) {
         log.info("======>" + versionClazz);
+
+        versionClazz = versionClazz.replace("&lt;", "<").replace("&gt;", ">");
+
         String ossFilePath = className + Suffix_JAVA;
         //创建服务器项目容器的java源码文件目录路径
         File serverFile = new File(engineWorkSourcePath, ossFilePath);