Results
1
comments of
joetao
放一下我的思路： 修改的是core这个模块 第一个修改JobAssignUtil类的doAssign方法：增加一个taskGourpId参数。原来的id是循环增加的。 ``` for (int i = 0; i < taskGroupNumber; i++) { tempTaskGroupConfig = taskGroupTemplate.clone(); tempTaskGroupConfig.set(CoreConstant.DATAX_JOB_CONTENT, taskGroupConfigList.get(i)); //原来的 tempTaskGroupConfig.set(CoreConstant.DATAX_CORE_CONTAINER_TASKGROUP_ID, i); //修改的 tempTaskGroupConfig.set(CoreConstant.DATAX_CORE_CONTAINER_TASKGROUP_ID, groupTaskId); result.add(tempTaskGroupConfig); } ``` 然后修改JobContainer类的logStatistic方法： ```...