diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java index 46e0b13a08..7ab2afd6af 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java @@ -112,7 +112,7 @@ public class UdfFuncService extends BaseService{ if (StringUtils.isNotEmpty(argTypes)) { udf.setArgTypes(argTypes); } - if (StringUtils.isNotEmpty(argTypes)) { + if (StringUtils.isNotEmpty(database)) { udf.setDatabase(database); } udf.setDescription(desc); @@ -214,19 +214,13 @@ public class UdfFuncService extends BaseService{ Date now = new Date(); udf.setFuncName(funcName); udf.setClassName(className); - if (StringUtils.isNotEmpty(argTypes)) { - udf.setArgTypes(argTypes); - } - if (StringUtils.isNotEmpty(argTypes)) { - udf.setDatabase(database); - } + udf.setArgTypes(argTypes); + udf.setDatabase(database); udf.setDescription(desc); udf.setResourceId(resourceId); udf.setResourceName(resource.getAlias()); udf.setType(type); - - udf.setCreateTime(now); udf.setUpdateTime(now); udfFuncMapper.updateById(udf); diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UsersService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UsersService.java index 0edc9b72bb..232eda0763 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UsersService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UsersService.java @@ -623,7 +623,7 @@ public class UsersService extends BaseService { return result; } - List userList = userMapper.selectList(null); + List userList = userMapper.queryAllGeneralUser(); List resultUsers = new ArrayList<>(); Set userSet = null; if (userList != null && userList.size() > 0) {