Wjcccccccccc opened a new issue #1995:
URL: https://github.com/apache/shardingsphere-elasticjob/issues/1995
## Bug Report
动态创建定时任务,每5秒执行一次,cron为`*/5 * * * * ?`
```
EventBus.fireEvent(new Event(EventBus.ASYNC_EVENT,
"CreateElasticjob: " + System.currentTimeMillis(), (Runnable) () -> {
new ScheduleJobBootstrap(
registryCenter,
this,
JobConfiguration
.newBuilder(jobName, 1)
.jobParameter(jobParameter)
.overwrite(true)
.monitorExecution(true)
.failover(true)
.jobErrorHandlerType("LOG")
.addExtraConfigurations(tracingConfiguration)
.cron(cron)
.build()
).schedule();
}));
```
部分任务执行正常,部分输出任务启动后,没有后续调度.
开启debug日志后发现
```
2021-10-09 06:47:31,145 | pk_status_push_17124_Worker-1 | | DEBUG |
org.apache.shardingsphere.elasticjob.reg.exception.RegExceptionHandler.handleException(RegExceptionHandler.java:44)
- Elastic job: ignored exception for: KeeperErrorCode = NoNode for
/jato-socket_prod/pk_status_push_17124/servers/172.31.43.84
```
凡是有此报错的都没有正常调度.
### Which version of ElasticJob did you use?
ElasticJob: 3.0.0
curator: 5.1.0
### Which project did you use? ElasticJob-Lite or ElasticJob-Cloud?
ElasticJob-Lite
### Expected behavior
创建任务后正常执行.
### Actual behavior
创建一个每5秒执行一次的任务,但是有时执行,有时不执行
### Reason analyze (If you can)
测试环境没有此问题,线上有,不确定是否与创建任务的体量有关.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
