You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/07/17 07:49:33 UTC

[shardingsphere-elasticjob] branch master updated: Update failover page (#1102)

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git


The following commit(s) were added to refs/heads/master by this push:
     new fcab2fc  Update failover page (#1102)
fcab2fc is described below

commit fcab2fcbbc152efae5667333da07d87cc260be86
Author: Liang Zhang <te...@163.com>
AuthorDate: Fri Jul 17 15:49:23 2020 +0800

    Update failover page (#1102)
    
    * Update elastic schedule
    
    * Update failover
---
 docs/content/features/elastic.cn.md       |   8 ++---
 docs/content/features/failover.cn.md      |  47 +++++++++++++++++++++++++++++-
 docs/static/img/failover/job-crash.png    | Bin 0 -> 85027 bytes
 docs/static/img/failover/job-failover.png | Bin 0 -> 85052 bytes
 docs/static/img/failover/job.png          | Bin 0 -> 77442 bytes
 5 files changed, 50 insertions(+), 5 deletions(-)

diff --git a/docs/content/features/elastic.cn.md b/docs/content/features/elastic.cn.md
index c18b2fe..ae1cc38 100644
--- a/docs/content/features/elastic.cn.md
+++ b/docs/content/features/elastic.cn.md
@@ -17,7 +17,7 @@ ElasticJob 中任务分片项的概念,使得任务可以在分布式的环境
 
 举例说明,如果作业分为 4 片,用两台服务器执行,则每个服务器分到 2 片,分别负责作业的 50% 的负载,如下图所示。
 
-[分片作业](https://shardingsphere.apache.org/elasticjob/current/img/elastic/sharding.png)
+![分片作业](https://shardingsphere.apache.org/elasticjob/current/img/elastic/sharding.png)
 
 ### 分片项
 
@@ -37,7 +37,7 @@ ElasticJob 并不直接提供数据处理的功能,而是将分片项分配至
 ElasticJob 提供最灵活的方式,最大限度的提高执行作业的吞吐量。
 当新增加作业服务器时,ElasticJob 会通过注册中心的临时节点的变化感知到新服务器的存在,并在下次任务调度的时候重新分片,新的服务器会承载一部分作业分片,如下图所示。
 
-[作业扩容](https://shardingsphere.apache.org/elasticjob/current/img/elastic/sacle-out.png)
+![作业扩容](https://shardingsphere.apache.org/elasticjob/current/img/elastic/sacle-out.png)
 
 将分片项设置为大于服务器的数量,最好是大于服务器倍数的数量,作业将会合理的利用分布式资源,动态的分配分片项。
 
@@ -50,7 +50,7 @@ ElasticJob 提供最灵活的方式,最大限度的提高执行作业的吞吐
 当作业服务器在运行中宕机时,注册中心同样会通过临时节点感知,并将在下次运行时将分片转移至仍存活的服务器,以达到作业高可用的效果。
 本次由于服务器宕机而未执行完的作业,则可以通过失效转移的方式继续执行。如下图所示。
 
-[作业高可用](https://shardingsphere.apache.org/elasticjob/current/img/elastic/ha.png)
+![作业高可用](https://shardingsphere.apache.org/elasticjob/current/img/elastic/ha.png)
 
 将分片总数设置为 1,并使用多于 1 台的服务器执行作业,作业将会以 1 主 n 从的方式执行。
-一旦执行作业的服务器崩溃,等待执行的服务器将会在下次作业启动时替补执行。开启失效转移功能效果更好,可以保证在本次作业执行时崩溃,备机立即启动替补执行。
+一旦执行作业的服务器宕机,等待执行的服务器将会在下次作业启动时替补执行。开启失效转移功能效果更好,可以保证在本次作业在执行时宕机的情况下,备机立即启动替补执行。
diff --git a/docs/content/features/failover.cn.md b/docs/content/features/failover.cn.md
index ddcf043..dbacb09 100644
--- a/docs/content/features/failover.cn.md
+++ b/docs/content/features/failover.cn.md
@@ -5,4 +5,49 @@ weight = 4
 chapter = true
 +++
 
-TODO
\ No newline at end of file
+ElasticJob 不会在本次执行过程中进行重新分片,而是等待下次调度之前才开启重新分片流程。
+当作业执行过程中服务器宕机,失效转移允许将该次未完成的任务在另一作业节点上补偿执行。
+
+## 概念
+
+失效转移是当前执行作业的临时补偿执行机制,再下次作业运行时,会通过重分片对当前作业分配进行调整。
+举例说明,若作业以每小时为间隔执行,每次执行耗时 30 分钟。如下如图所示。
+
+![定时作业](https://shardingsphere.apache.org/elasticjob/current/img/failover/job.png)
+
+图中表示作业分别于 12:00,13:00 和 14:00 执行。图中显示的当前时间点为 13:00 的作业执行中。
+
+如果作业的其中一个分片服务器在 13:10 的时候宕机,那么剩余的 20 分钟应该处理的业务未得到执行,并且需要在 14:00 时才能再次开始执行下一次作业。
+也就是说,在不开启失效转移的情况下,位于该分片的作业有 50 分钟空档期。如下如图所示。
+
+![作业宕机](https://shardingsphere.apache.org/elasticjob/current/img/failover/job-crash.png)
+
+在开启失效转移功能之后,ElasticJob 的其他服务器能够在感知到宕机的作业服务器之后,补偿执行该分片作业。如下图所示。
+
+![补偿执行](https://shardingsphere.apache.org/elasticjob/current/img/failover/job-failover.png)
+
+在资源充足的情况下,作业仍然能够在 13:30 完成执行。
+
+## 执行机制
+
+当作业执行节点宕机时,会触发失效转移流程。ElasticJob 根据触发时的分布式作业执行的不同状况来决定失效转移的执行时机。
+
+### 通知执行
+
+当其他服务器感知到有失效转移的作业需要处理时,且该作业服务器已经完成了本次任务,则会实时的拉取待失效转移的分片项,并开始补偿执行。
+也称为实时执行。
+
+### 问询执行
+
+作业服务在本次任务执行结束后,会向注册中心问询待执行的失效转移分片项,如果有,则开始补偿执行。
+也称为异步执行。
+
+## 适用场景
+
+开启失效转移功能,ElasticJob 会监控作业每一分片的执行状态,并将其写入注册中心,供其他节点感知。
+
+在一次运行耗时较长且间隔较长的作业场景,失效转移是提升作业运行实时性的有效手段;
+对于间隔较短的作业,会产生大量与注册中心的网络通信,对集群的性能产生影响。
+而且间隔较短的作业并未见得关注单次作业的实时性,可以通过下次作业执行的重分片使所有的分片正确执行,因此不建议短间隔作业开启失效转移。
+
+另外需要注意的是,作业本身的幂等性,是保证失效转移正确性的前提。
diff --git a/docs/static/img/failover/job-crash.png b/docs/static/img/failover/job-crash.png
new file mode 100644
index 0000000..d0edb8f
Binary files /dev/null and b/docs/static/img/failover/job-crash.png differ
diff --git a/docs/static/img/failover/job-failover.png b/docs/static/img/failover/job-failover.png
new file mode 100644
index 0000000..7014c3f
Binary files /dev/null and b/docs/static/img/failover/job-failover.png differ
diff --git a/docs/static/img/failover/job.png b/docs/static/img/failover/job.png
new file mode 100644
index 0000000..d16c615
Binary files /dev/null and b/docs/static/img/failover/job.png differ