提交 fb90fcea 编写于 作者: L lidongdai

Merge remote-tracking branch 'upstream/dev' into dev

...@@ -92,8 +92,8 @@ public class ExecutorController extends BaseController { ...@@ -92,8 +92,8 @@ public class ExecutorController extends BaseController {
logger.info("login user {}, start process instance, project name: {}, process definition id: {}, schedule time: {}, " logger.info("login user {}, start process instance, project name: {}, process definition id: {}, schedule time: {}, "
+ "failure policy: {}, node name: {}, node dep: {}, notify type: {}, " + "failure policy: {}, node name: {}, node dep: {}, notify type: {}, "
+ "notify group id: {},receivers:{},receiversCc:{}, run mode: {},process instance priority:{}, workerGroupId: {}, timeout: {}", + "notify group id: {},receivers:{},receiversCc:{}, run mode: {},process instance priority:{}, workerGroupId: {}, timeout: {}",
loginUser.getUserName(), projectName, processDefinitionId, scheduleTime, failureStrategy, loginUser.getUserName(), projectName, processDefinitionId, scheduleTime,
taskDependType, warningType, warningGroupId,receivers,receiversCc,runMode,processInstancePriority, failureStrategy, startNodeList, taskDependType, warningType, warningGroupId,receivers,receiversCc,runMode,processInstancePriority,
workerGroupId, timeout); workerGroupId, timeout);
if (timeout == null) { if (timeout == null) {
......
...@@ -344,9 +344,12 @@ public abstract class AbstractZKClient { ...@@ -344,9 +344,12 @@ public abstract class AbstractZKClient {
String parentPath = getZNodeParentPath(zkNodeType); String parentPath = getZNodeParentPath(zkNodeType);
List<MasterServer> masterServers = new ArrayList<>(); List<MasterServer> masterServers = new ArrayList<>();
int i = 0;
for(String path : masterMap.keySet()){ for(String path : masterMap.keySet()){
MasterServer masterServer = ResInfo.parseHeartbeatForZKInfo(masterMap.get(path)); MasterServer masterServer = ResInfo.parseHeartbeatForZKInfo(masterMap.get(path));
masterServer.setZkDirectory( parentPath + "/"+ path); masterServer.setZkDirectory( parentPath + "/"+ path);
masterServer.setId(i);
i ++;
masterServers.add(masterServer); masterServers.add(masterServer);
} }
return masterServers; return masterServers;
......
...@@ -18,6 +18,6 @@ ...@@ -18,6 +18,6 @@
/** /**
* Create file type * Create file type
*/ */
let filtTypeArr = ['txt', 'log', 'sh', 'conf', 'cfg', 'py', 'java', 'sql', 'xml', 'hql'] let filtTypeArr = ['txt', 'log', 'sh', 'conf', 'cfg', 'py', 'java', 'sql', 'xml', 'hql', 'properties']
export { filtTypeArr } export { filtTypeArr }
...@@ -28,7 +28,8 @@ const handlerSuffix = { ...@@ -28,7 +28,8 @@ const handlerSuffix = {
'.java': 'textile', '.java': 'textile',
'.sql': 'sql', '.sql': 'sql',
'.hql': 'sql', '.hql': 'sql',
'.xml': 'xml' '.xml': 'xml',
'.properties': 'textile'
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册