Browse Source

update

pull/2/head
lenboo 5 years ago
parent
commit
65015f98d4
  1. 2
      escheduler-api/src/main/java/cn/escheduler/api/service/ProcessInstanceService.java
  2. 2
      escheduler-common/src/main/java/cn/escheduler/common/Constants.java

2
escheduler-api/src/main/java/cn/escheduler/api/service/ProcessInstanceService.java

@ -116,7 +116,7 @@ public class ProcessInstanceService extends BaseDAGService {
} }
ProcessInstance processInstance = processDao.findProcessInstanceDetailById(processId); ProcessInstance processInstance = processDao.findProcessInstanceDetailById(processId);
if(processInstance.getWorkerGroupId() == -1){ if(processInstance.getWorkerGroupId() == -1){
processInstance.setWorkerGroupName("Default"); processInstance.setWorkerGroupName(DEFAULT);
}else{ }else{
WorkerGroup workerGroup = workerGroupMapper.queryById(processInstance.getWorkerGroupId()); WorkerGroup workerGroup = workerGroupMapper.queryById(processInstance.getWorkerGroupId());
processInstance.setWorkerGroupName(workerGroup.getName()); processInstance.setWorkerGroupName(workerGroup.getName());

2
escheduler-common/src/main/java/cn/escheduler/common/Constants.java

@ -483,6 +483,8 @@ public final class Constants {
public static final String TASK_RECORD_PWD = "task.record.datasource.password"; public static final String TASK_RECORD_PWD = "task.record.datasource.password";
public static final String DEFAULT = "Default";
public static String TASK_RECORD_TABLE_HIVE_LOG = "eamp_hive_log_hd"; public static String TASK_RECORD_TABLE_HIVE_LOG = "eamp_hive_log_hd";
public static String TASK_RECORD_TABLE_HISTORY_HIVE_LOG = "eamp_hive_hist_log_hd"; public static String TASK_RECORD_TABLE_HISTORY_HIVE_LOG = "eamp_hive_hist_log_hd";

Loading…
Cancel
Save