Skip to content

Commit 2e1eb79

Browse files
committed
优化getSparkVersion代码
1 parent 8d906f4 commit 2e1eb79

File tree

1 file changed

+3
-6
lines changed
  • dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl

1 file changed

+3
-6
lines changed

dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -284,19 +284,16 @@ private void enrichParams(Job job) {
284284
}
285285

286286
private String getSparkVersion(Map<String, Object> params) {
287-
288287
String sparkVersion = null;
289-
290-
if (params.get("configuration") != null) {
288+
if (params.get("configuration") instanceof Map) {
291289
Map<String, Object> configurationMap = (Map<String, Object>) params.get("configuration");
292-
if (configurationMap.get("runtime") != null) {
290+
if (configurationMap.get("runtime") instanceof Map) {
293291
Map<String, Object> runtimeMap = (Map<String, Object>) configurationMap.get("runtime");
294-
if (runtimeMap.get("sparkVersion") != null) {
292+
if (runtimeMap.get("sparkVersion") instanceof String) {
295293
sparkVersion = (String) runtimeMap.get("sparkVersion");
296294
}
297295
}
298296
}
299-
300297
return sparkVersion;
301298
}
302299

0 commit comments

Comments
 (0)