diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java index 95e18cc9a9..ffb6febd66 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java @@ -457,9 +457,12 @@ public class ProcessDao { if(tenantId >= 0){ tenant = tenantMapper.queryById(tenantId); } - if(tenant == null){ + if(null == tenant){ User user = userMapper.selectById(userId); - tenant = tenantMapper.queryById(user.getTenantId()); + + if (null != user) { + tenant = tenantMapper.queryById(user.getTenantId()); + } } return tenant; }