Skip to content

Commit 22f0e1c

Browse files
committed
fix: 全局变量剔除代理用户后再放到schedulis props中#AI Commit#
1 parent b153002 commit 22f0e1c

File tree

1 file changed

+4
-1
lines changed
  • plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype

1 file changed

+4
-1
lines changed

plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/AzkabanDssJobType.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,10 @@ private Map<String, String> collectFlowVariablesFromJobProps() {
183183
if (entry.getKey() != null
184184
&& entry.getKey().startsWith(LinkisJobTypeConf.FLOW_VARIABLE_PREFIX)
185185
&& entry.getValue() != null) {
186-
flowVariables.put(entry.getKey().substring(LinkisJobTypeConf.FLOW_VARIABLE_PREFIX.length()), entry.getValue());
186+
String variableKey = entry.getKey().substring(LinkisJobTypeConf.FLOW_VARIABLE_PREFIX.length());
187+
if (!"user.to.proxy".equals(variableKey)) {
188+
flowVariables.put(variableKey, entry.getValue());
189+
}
187190
}
188191
}
189192
return flowVariables;

0 commit comments

Comments
 (0)