1.0.8【bug】 通过程序代码删除Job，报NumberFormatException异常，导致Job部分节点没有完全清除 #99
Comments
|
不知道为什么，现在删除不报异常了，zk中节点也都删除了。。。 |
|
可能是zk延迟导致的。我们也考虑使用别的注册中心替换zk，但没那么快。 |
|
不好意思亮哥，删除问题还是有，虽然没有异常，但是需要连续删两次，第二次才会清除zk中的节点Job 操作步骤：1. 创建Job，先跑一次2. 通过程序代码删除Job，调用方法关键点如下(注意：以下方法先执行一次)：// 2.1, 先关闭Job // 2.2, 在删除Job(会清空zk中节点) 3. 查看zk中的Job节点还是存在的4. 再次执行 第2.1、2.2的代码5. zk中Job节点删除成功问题：需要调用两次删除，才真的删除zk中的Job节点。 |
|
删除Job时候，有时候还是会有NumberFormatException异常 [JOB] 2016-05-31-15:00:30.441 [DEFAULT.059CC194C0A802E4132FD022D84A1AE4_Scheduler_Worker-1] ERROR c.d.d.j.p.j.t.s.AbstractSimpleElasticJob - Elastic job: exception occur in job processing... |
|
可以删除时先sleep一下，看看是否删除成功了么，是不是延迟导致 |
|
关闭任务后延迟500ms，然后在执行删除操作，还是报NumberFormatException异常 |
|
调用SHUTDOWN方法不会报异常，只要调用REMOVE，几乎都会报这个NumberFormatException异常。 |
|
我觉得问题的症结可能在这里： public void shutdown() {
**schedulerFacade.releaseJobResource();**
try {
if (!scheduler.isShutdown()) {
scheduler.shutdown();
}
} catch (final SchedulerException ex) {
throw new JobException(ex);
}
}**其中的清理资源在quartz调度器关闭之前完成。**那么shutdown命令被监听器处理之后，正在运行的一次任务尚未完成，此时调用remove，remove看到STATUS节点已经被删除，那么他就会删除对应任务的节点，故而在正在运行的这次任务执行到最后时，调用GuaranteeService.isAllCompleted获取shardingitem时找不到节点，故而出错。 后来， @gaoyaqiu 出现两次才能remove，可能是因为第一次删除的时间点时，shutdown监听器还没有删除STATUS节点，remove方法直接返回了。 @Override
public Collection<String> remove(final Optional<String> jobName, final Optional<String> serverIp) {
return jobOperatorTemplate.operate(jobName, serverIp, new JobOperateCallback() {
@Override
public boolean doOperate(final String jobName, final String serverIp) {
JobNodePath jobNodePath = new JobNodePath(jobName);
if (registryCenter.isExisted(jobNodePath.getServerNodePath(serverIp, JobNodePath.STATUS_NODE))) {
return false;
}
registryCenter.remove(jobNodePath.getServerNodePath(serverIp));
if (registryCenter.getChildrenKeys(jobNodePath.getServerNodePath()).isEmpty()) {
registryCenter.remove("/" + jobName);
}
return true;
}
});
}如果这里调整之后，会出现由于zk延时和当前任务执行延时，造成remove一直不起效的情况，那么此时如果一定要删除zk节点（其实，我觉得没有必要，毕竟shutdown已经关闭了定时任务，zk节点保留着也没什么影响），可以使用while删除，一直到remove方法返回true为止。 应该也可以把创建JobScheduler的地方不写SimpleDistributeOnceElasticJobListener，这样就不会调用isCompleted方法去检查了，也就不会报合格NumberFormat异常了。 new JobScheduler(regCenter, simpleJobConfig, new SimpleDistributeOnceElasticJobListener()).init();-----> new JobScheduler(regCenter, simpleJobConfig).init(); |
|
目前已知两个问题：
|
|
你好，请教一下，删除任务的功能怎么实现的 |
1. 调用方法关键点如下：
// 先关闭Job
jobAPIService.getJobOperatorAPI().shutdown(Optional.of(jobServer.getJobName()), Optional.absent());
// 在删除Job(会清空zk中节点)
jobAPIService.getJobOperatorAPI().remove(Optional.of(jobServer.getJobName()), Optional.absent());
# 2. 异常如下：
[JOB] 2016-05-27-19:23:10.251 [DEFAULT.ED8A44CDC0A8C7792D59468EE687552C_Scheduler_Worker-1] ERROR c.d.d.j.p.j.t.s.AbstractSimpleElasticJob - Elastic job: exception occur in job processing...
java.lang.NumberFormatException: null
at java.lang.Integer.parseInt(Integer.java:542) ~[na:1.8.0_45]
at java.lang.Integer.parseInt(Integer.java:615) ~[na:1.8.0_45]
at com.dangdang.ddframe.job.internal.config.ConfigurationService.getShardingTotalCount(ConfigurationService.java:88) ~[elastic-job-core-1.0.8.jar:na]
at com.dangdang.ddframe.job.internal.guarantee.GuaranteeService.isAllCompleted(GuaranteeService.java:87) ~[elastic-job-core-1.0.8.jar:na]
at com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener.afterJobExecuted(AbstractDistributeOnceElasticJobListener.java:84) ~[elastic-job-core-1.0.8.jar:na]
at com.dangdang.ddframe.job.internal.schedule.JobFacade.afterJobExecuted(JobFacade.java:246) ~[elastic-job-core-1.0.8.jar:na]
at com.dangdang.ddframe.job.internal.job.AbstractElasticJob.execute(AbstractElasticJob.java:68) ~[elastic-job-core-1.0.8.jar:na]
at org.quartz.core.JobRunShell.run(JobRunShell.java:202) [quartz-2.2.2.jar:na]
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573) [quartz-2.2.2.jar:na]
The text was updated successfully, but these errors were encountered: