Skip to content

Commit 95d50e2

Browse files
committed
Merge branch 'dev-1.21.0' into dev-1.21.0-hadoop3
2 parents 33ffafa + 22f0e1c commit 95d50e2

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

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

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)