elastic-job分片失效转移的问题

Question

最近在看elastc-job-lite(2.1.4)的源码,关于分片失效转移的入口有两个

1.在AbstractElasticJobExecutor中方法execute()调用了jobFacade.failoverIfNecessary()方法

2.在FailoverListenerManager类中有个JobCrashedJobListener的监听器也调用了failoverService.failoverIfNecessary()方法

failoverIfNecessary方法的作用就是选举主节点，使用jobScheduleController.triggerJob()方法重新触发了job。我感觉只要第一个入口就行了，为什么还要第一个入口呢？

 

Answer 1

楼主，这块是对job进行失效转移还是对分片进行失效转移？

Answer 2

谢谢亮哥的回答

Answer 3

请教一下，关于节点失效转移的时间问题，我这边一直是大于3分钟之后才会开始将任务转移到新的节点，我配置了失效时间和失效请求次数，都没有缩短任务从新转移到新的节点的时间。求教一下，我应该如何处理

Answer 4

一个是有节点挂掉之后查看有无空闲机器可以执行实效转移，如有，则被分配为被动执行；另一个是有主机运行完毕后查看又无实效转移的节点要执行，属于主动抓取。两种方式互补，缺一不可