You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by GitBox <gi...@apache.org> on 2021/01/08 03:06:58 UTC
[GitHub] [shardingsphere-elasticjob] WooXooM opened a new issue #1808: 定时任务执行完成之后，进入了重试机制
WooXooM opened a new issue #1808:
URL: https://github.com/apache/shardingsphere-elasticjob/issues/1808
是用的版本是elastic-job-lite 2.1.5
定时任务执行成功了，中间没有抛异常，但是进入了重试。重试配置的是maxRetries=3， baseSleepTimeMilliseconds=1000， maxSleepTimeMilliseconds=3000。定时任务执行完成之后，又在30秒之后执行了一次，然后30秒之后又执行了一次。
执行成功之后，发现上送的结果是request:: '/test-job/errorLogMonitorJob/sharding/0/running,-1
下面是日志
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:null serverPath:null finished:false header:: 137918,3 replyHeader:: 137918,124916452976,0 request:: '/test-job/errorLogMonitorJob/sharding/0/running,F response:: s{124916452952,124916452952,1610013058012,1610013058012,0,0,0,33246263107878543,0,0,124916452952} ]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:741) [Got notification sessionid:0x761d4cd6a77e8f][DEBUG 2021-01-07 17:50:58.163] [SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:763) [Got WatchedEvent state:SyncConnected type:NodeDeleted path:/test-job/errorLogMonitorJob/sharding/0/running for sessionid 0x761d4cd6a77e8f]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:741) [Got notification sessionid:0x761d4cd6a77e8f][DEBUG 2021-01-07 17:50:58.163] [EventThread] [] TreeCache.process(TreeCache.java:341) [process: WatchedEvent state:SyncConnected type:NodeDeleted path:/errorLogMonitorJob/sharding/0/running]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:763) [Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/test-job/errorLogMonitorJob/sharding/0 for sessionid 0x761d4cd6a77e8f]
[EventThread] [] TreeCache.publishEvent(TreeCache.java:834) [publishEvent: TreeCacheEvent{type=NODE_REMOVED, data=ChildData{path='/errorLogMonitorJob/sharding/0/running', stat=124916452952,124916452952,1610013058012,1610013058012,0,0,0,33246263107878543,0,0,124916452952, data=[]}}]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:null serverPath:null finished:false header:: 137919,2 replyHeader:: 137919,124916452978,0 request:: '/test-job/errorLogMonitorJob/sharding/0/running,-1 response:: null]
[EventThread] [] TreeCache.process(TreeCache.java:341) [process: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/errorLogMonitorJob/sharding/0]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:null serverPath:null finished:false header:: 137920,3 replyHeader:: 137920,124916452978,0 request:: '/test-job/errorLogMonitorJob/leader/election/instance,F response:: s{124916067793,124916067793,1610009670012,1610009670012,0,0,0,33246263107878543,19,0,124916067793} ]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:null serverPath:null finished:false header:: 137921,3 replyHeader:: 137921,124916452978,-101 request:: '/test-job/errorLogMonitorJob/leader/sharding/necessary,F response:: ]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:/test-job/errorLogMonitorJob/sharding/0 serverPath:/test-job/errorLogMonitorJob/sharding/0 finished:false header:: 137922,12 replyHeader:: 137922,124916452978,0 request:: '/test-job/errorLogMonitorJob/sharding/0,T response:: v{'instance},s{122601031744,122601031744,1598593909804,1598593909804,0,2279171,0,0,0,1,124916452978} ]
[EventThread] [] TreeCache.processResult(TreeCache.java:371) [processResult: CuratorEventImpl{type=CHILDREN, resultCode=0, path='/errorLogMonitorJob/sharding/0', name='null', children=[instance], context=null, stat=122601031744,122601031744,1598593909804,1598593909804,0,2279171,0,0,0,1,124916452978, data=null, watchedEvent=null, aclList=null}]
[SendThread(zk:2181)] [] ClientCnxn.readResponse(ClientCnxn.java:818) [Reading reply sessionid:0x761d4cd6a77e8f, packet:: clientPath:null serverPath:null finished:false header:: 137923,3 replyHeader:: 137923,124916452978,-101 request:: '/test-job/errorLogMonitorJob/sharding/0/misfire,F response:: ]
[errorLogMonitorJob_QuartzSchedulerThread] [] QuartzSchedulerThread.run(QuartzSchedulerThread.java:276) [batch acquisition of 1 triggers]
[Thread-60] [] PoolingHttpClientConnectionManager.closeExpiredConnections(PoolingHttpClientConnectionManager.java:428) [Closing expired connections]
[Thread-60] [] PoolingHttpClientConnectionManager.closeIdleConnections(PoolingHttpClientConnectionManager.java:421) [Closing connections idle longer than 30 SECONDS]
[errorLogMonitorJob_QuartzSchedulerThread] [] PropertySettingJobFactory.newJob(SimpleJobFactory.java:51) [Producing instance of Job 'DEFAULT.errorLogMonitorJob', class=com.dangdang.ddframe.job.lite.internal.schedule.LiteJob]
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [shardingsphere-elasticjob] TeslaCN closed issue #1808: 定时任务执行完成之后，进入了重试机制
Posted by GitBox <gi...@apache.org>.
TeslaCN closed issue #1808:
URL: https://github.com/apache/shardingsphere-elasticjob/issues/1808
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [shardingsphere-elasticjob] TeslaCN commented on issue #1808: 定时任务执行完成之后，进入了重试机制
Posted by GitBox <gi...@apache.org>.
TeslaCN commented on issue #1808:
URL: https://github.com/apache/shardingsphere-elasticjob/issues/1808#issuecomment-756520393
**For English only**
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org