Skip to content

Commit f5d714a

Browse files
committed
fix: 拷贝工作流,修改代理用户bug
1 parent f449618 commit f5d714a

File tree

1 file changed

+2
-4
lines changed
  • dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/service/impl

1 file changed

+2
-4
lines changed

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/service/impl/DSSFlowServiceImpl.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1224,7 +1224,9 @@ private String updateFlowProxyUser(String flowJson,String flowProxyUser,Long orc
12241224
String proxyUser = "";
12251225
for (Map<String, Object> prop : props) {
12261226
if (prop.containsKey("user.to.proxy") && prop.get("user.to.proxy") != null) {
1227+
// 代理用户不为空,替换代理用户
12271228
proxyUser = prop.get("user.to.proxy").toString();
1229+
prop.put("user.to.proxy",flowProxyUser);
12281230
break;
12291231
}
12301232
}
@@ -1235,10 +1237,6 @@ private String updateFlowProxyUser(String flowJson,String flowProxyUser,Long orc
12351237
// 原工作流代理用户不为空,拷贝后的工作流 代理用户信息则进行替换
12361238
if(StringUtils.isNotEmpty(proxyUser)){
12371239

1238-
for (Map<String, Object> prop : props) {
1239-
prop.put("user.to.proxy",flowProxyUser);
1240-
}
1241-
12421240
flowJson = workFlowParser.updateFlowJsonWithKey(flowJson, "props", props);
12431241

12441242
Map<String,Object> scheduleParams = new HashMap<>();

0 commit comments

Comments
 (0)