third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: NPE when InstanceTimeLimit is null #207

Browse Source
This commit is contained in:
tjq 2021-02-06 15:37:12 +08:00
parent d06e5bc029
commit e97bdc71c7
4 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/JobService.java
View File

@ -233,6 +233,9 @@ public class JobService {
if (jobInfoDO.getTaskRetryNum() == null) { if (jobInfoDO.getTaskRetryNum() == null) {
jobInfoDO.setTaskRetryNum(0); jobInfoDO.setTaskRetryNum(0);
} }
if (jobInfoDO.getInstanceTimeLimit() == null) {
jobInfoDO.setInstanceTimeLimit(0L);
}
} }
private static JobInfoDTO convert(JobInfoDO jobInfoDO) { private static JobInfoDTO convert(JobInfoDO jobInfoDO) {

1
powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/processors/BroadcastProcessorDemo.java
View File

@ -13,7 +13,6 @@ import java.util.List;
/** /**
* 广播处理器 示例 * 广播处理器 示例
* com.github.kfcfans.oms.server.processors.BroadcastProcessorDemo
* *
* @author tjq * @author tjq
* @since 2020/4/17 * @since 2020/4/17

3
powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/processors/MapReduceProcessorDemo.java
View File

@ -21,8 +21,7 @@ import java.util.concurrent.ThreadLocalRandom;
/** /**
* MapReduce 处理器示例 * MapReduce 处理器示例
* com.github.kfcfans.oms.server.processors.MapReduceProcessorDemo * 控制台参数：{"batchSize": 100, "batchNum": 2}
* {"batchSize": 100, "batchNum": 2}
* *
* @author tjq * @author tjq
* @since 2020/4/17 * @since 2020/4/17

2
powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/processors/StandaloneProcessorDemo.java
View File

@ -11,7 +11,7 @@ import java.util.Collections;
/** /**
* 单机处理器 示例 * 单机处理器 示例
* com.github.kfcfans.oms.server.processors.StandaloneProcessorDemo * com.github.kfcfans.powerjob.samples.processors.StandaloneProcessorDemo
* *
* @author tjq * @author tjq
* @since 2020/4/17 * @since 2020/4/17