在创建xxl-job任务时候,文件JobClientApi.java中:
JobGroupPageListResp jobGroupPageListResp = this.jobGroupPage(this.getDefaultJobGroupParam());
Long jobGroupId = jobGroupPageListResp.getData().stream().findFirst().map(JobGroupPageListResp.JobGroupDetail::getId)
public PageQueryParam getDefaultJobGroupParam() {
return PageQueryParam
.builder()
.appname(GLOBAL_COMMON_GROUP)
.title(GLOBAL_COMMON_GROUP)
.start(0)
.length(10)
.build();
}
其中GLOBAL_COMMON_GROUP = datalinkx,与datalinkx-job中的appname: dataTransJobHandler不匹配导致动态设置jobGroupId时候未正确设置分组,把datalinkx-job中的appname设置成datalinkx即可解决
在创建xxl-job任务时候,文件JobClientApi.java中:
其中
GLOBAL_COMMON_GROUP = datalinkx,与datalinkx-job中的appname: dataTransJobHandler不匹配导致动态设置jobGroupId时候未正确设置分组,把datalinkx-job中的appname设置成datalinkx即可解决