Skip to content

Commit

Permalink
fix #302
Browse files Browse the repository at this point in the history
  • Loading branch information
@terrymanu
terrymanu committed Apr 28, 2017
1 parent 3cfbec3 commit 9fb314b
Show file tree
Hide file tree
Showing 12 changed files with 193 additions and 158 deletions.
3 changes: 1 addition & 2 deletions elastic-job-doc/elastic-job-cloud-doc/content/00-overview/release-notes.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,10 @@ next = "/00-overview/contribution/"

## 2.1.2

### 新功能

### 功能提升

1. [ISSUE #296](https://github.com/dangdangdotcom/elastic-job/issues/296) Elastic-Job-Cloud运维界面重构
1. [ISSUE #302](https://github.com/dangdangdotcom/elastic-job/issues/302) Failover与MonitorExecution分离

### 缺陷修正

Expand Down
40 changes: 20 additions & 20 deletions elastic-job-doc/elastic-job-cloud-doc/content/02-guide/event-trace.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,16 +19,16 @@ JOB_EXECUTION_LOG字段含义

| 字段名称 | 字段类型 | 是否必填 | 描述 |
| ----------------- |:------------|:--------|:------------------------------------------------------------------------------------------------|
|id |VARCHAR(40) |是 | 主键 |
|job_name |VARCHAR(100) |是 | 作业名称 |
|task_id |VARCHAR(1000)|是 | 任务名称,每次作业运行生成新任务 |
|hostname |VARCHAR(255) |是 | 主机名称 |
|ip |VARCHAR(50) |是 | 主机IP |
|sharding_item |INT |是 | 分片项 |
|execution_source |VARCHAR(20) |是 | 作业执行来源。可选值为NORMAL_TRIGGER, MISFIRE, FAILOVER |
|id |VARCHAR(40) |是 | 主键 |
|job_name |VARCHAR(100) |是 | 作业名称 |
|task_id |VARCHAR(1000)|是 | 任务名称,每次作业运行生成新任务 |
|hostname |VARCHAR(255) |是 | 主机名称 |
|ip |VARCHAR(50) |是 | 主机IP |
|sharding_item |INT |是 | 分片项 |
|execution_source |VARCHAR(20) |是 | 作业执行来源。可选值为NORMAL_TRIGGER, MISFIRE, FAILOVER |
|failure_cause |VARCHAR(2000)|否 | 执行失败原因 |
|is_success |BIT |是 | 是否执行成功 |
|start_time |TIMESTAMP |是 | 作业开始执行时间 |
|is_success |BIT |是 | 是否执行成功 |
|start_time |TIMESTAMP |是 | 作业开始执行时间 |
|complete_time |TIMESTAMP |否 | 作业结束执行时间 |


Expand All @@ -44,16 +44,16 @@ JOB_STATUS_TRACE_LOG字段含义

| 字段名称 | 字段类型 | 是否必填 | 描述 |
| ----------------- |:------------|:--------|:--------------------------------------------------------------------------------------------------------------------------|
|id |VARCHAR(40) |是 | 主键 |
|job_name |VARCHAR(100) |是 | 作业名称 |
|original_task_id |VARCHAR(1000)|是 | 原任务名称 |
|task_id |VARCHAR(1000)|是 | 任务名称 |
|slave_id |VARCHAR(1000)|是 | 执行作业服务器的名称，Lite版本为服务器的IP地址，Cloud版本为Mesos执行机主键 |
|source |VARCHAR(50) |是 | 任务执行源，可选值为CLOUD_SCHEDULER, CLOUD_EXECUTOR, LITE_EXECUTOR |
|execution_type |VARCHAR(20) |是 | 任务执行类型，可选值为NORMAL_TRIGGER, MISFIRE, FAILOVER |
|sharding_item |VARCHAR(255) |是 | 分片项集合，多个分片项以逗号分隔 |
|state |VARCHAR(20) |是 | 任务执行状态，可选值为TASK_STAGING, TASK_RUNNING, TASK_FINISHED, TASK_KILLED, TASK_LOST, TASK_FAILED, TASK_ERROR|
|message |VARCHAR(2000)|是 | 相关信息 |
|creation_time |TIMESTAMP |是 | 记录创建时间 |
|id |VARCHAR(40) |是 | 主键 |
|job_name |VARCHAR(100) |是 | 作业名称 |
|original_task_id |VARCHAR(1000)|是 | 原任务名称 |
|task_id |VARCHAR(1000)|是 | 任务名称 |
|slave_id |VARCHAR(1000)|是 | 执行作业服务器的名称，Lite版本为服务器的IP地址，Cloud版本为Mesos执行机主键 |
|source |VARCHAR(50) |是 | 任务执行源，可选值为CLOUD_SCHEDULER, CLOUD_EXECUTOR, LITE_EXECUTOR |
|execution_type |VARCHAR(20) |是 | 任务执行类型，可选值为NORMAL_TRIGGER, MISFIRE, FAILOVER |
|sharding_item |VARCHAR(255) |是 | 分片项集合，多个分片项以逗号分隔 |
|state |VARCHAR(20) |是 | 任务执行状态，可选值为TASK_STAGING, TASK_RUNNING, TASK_FINISHED, TASK_KILLED, TASK_LOST, TASK_FAILED, TASK_ERROR |
|message |VARCHAR(2000)|是 | 相关信息 |
|creation_time |TIMESTAMP |是 | 记录创建时间 |

JOB_STATUS_TRACE_LOG记录作业状态变更痕迹表。可通过每次作业运行的task_id查询作业状态变化的生命周期和运行轨迹。
7 changes: 7 additions & 0 deletions elastic-job-doc/elastic-job-lite-doc/content/00-overview/release-notes.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,13 @@ prev = "/00-overview/intro/"
next = "/00-overview/contribution/"
+++

## 2.1.2

### 功能提升

1. [ISSUE #296](https://github.com/dangdangdotcom/elastic-job/issues/296) Elastic-Job-Cloud运维界面重构
1. [ISSUE #302](https://github.com/dangdangdotcom/elastic-job/issues/302) Failover与MonitorExecution分离

## 2.1.1

### 新功能
Expand Down
16 changes: 8 additions & 8 deletions elastic-job-doc/elastic-job-lite-doc/content/02-guide/config-manual.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ JobTypeConfiguration根据不同实现类型分为SimpleJobConfiguration，Dataf
| shardingTotalCount | int | 是 | | 作业分片总数 |
| shardingItemParameters | String | 否 | | 分片序列号和参数用等号分隔，多个键值对用逗号分隔<br />分片序列号从0开始，不可大于或等于作业分片总数<br />如：<br/>0=a,1=b,2=c |
| jobParameter | String | 否 | | 作业自定义参数<br />作业自定义参数，可通过传递该参数为作业调度的业务方法传参，用于实现带参数的作业<br />例：每次获取的数据量、作业实例从数据库读取的主键等 |
| failover | boolean | 否 | false | 是否开启失效转移<br />仅monitorExecution开启，失效转移才有效 |
| failover | boolean | 否 | false | 是否开启失效转移 |
| misfire | boolean | 否 | true | 是否开启错过任务重新执行 |
| description | String | 否 | | 作业描述信息 |
| jobProperties | Enum | 否 | | 配置jobProperties定义的枚举控制Elastic-Job的实现细节<br />JOB_EXCEPTION_HANDLER用于扩展异常处理类<br />EXECUTOR_SERVICE_HANDLER用于扩展作业处理线程池类|
Expand Down Expand Up @@ -114,18 +114,18 @@ Spring命名空间与Java Code方式配置类似，大部分属性只是将命

| 属性名 | 类型 | 是否必填 | 缺省值 | 描述 |
| ------------------------------------|:--------|:--------|:----------------|:---------------------------------------------------------------------------|
| id | String | 是 | | 作业名称 |
| class | String | 否 | | 作业实现类，需实现ElasticJob接口 |
| registry-center-ref | String | 是 | | 注册中心Bean的引用，需引用reg:zookeeper的声明 |
| cron | String | 是 | | cron表达式，用于控制作业触发时间 |
| sharding-total-count | int | 是 | | 作业分片总数 |
| id | String | 是 | | 作业名称 |
| class | String | 否 | | 作业实现类，需实现ElasticJob接口 |
| registry-center-ref | String | 是 | | 注册中心Bean的引用，需引用reg:zookeeper的声明 |
| cron | String | 是 | | cron表达式，用于控制作业触发时间 |
| sharding-total-count | int | 是 | | 作业分片总数 |
| sharding-item-parameters | String | 否 | | 分片序列号和参数用等号分隔，多个键值对用逗号分隔<br />分片序列号从0开始，不可大于或等于作业分片总数<br />如：<br/>0=a,1=b,2=c|
| job-instance-id | String | 否 | defaultInstance | 作业实例主键，同IP可运行实例主键不同, 但名称相同的多个作业实例 |
| job-parameter | String | 否 | | 作业自定义参数<br />作业自定义参数，可通过传递该参数为作业调度的业务方法传参，用于实现带参数的作业<br />例：每次获取的数据量、作业实例从数据库读取的主键等 |
| monitor-execution | boolean | 否 | true | 监控作业运行时状态<br />每次作业执行时间和间隔时间均非常短的情况，建议不监控作业运行时状态以提升效率。因为是瞬时状态，所以无必要监控。请用户自行增加数据堆积监控。并且不能保证数据重复选取，应在作业中实现幂等性。<br />每次作业执行时间和间隔时间均较长的情况，建议监控作业运行时状态，可保证数据不会重复选取。|
| monitor-port | int | 否 | -1 | 作业监控端口<br />建议配置作业监控端口, 方便开发者dump作业信息。<br />使用方法: echo "dump" \| nc 127.0.0.1 9888|
| max-time-diff-seconds | int | 否 | -1 | 最大允许的本机与注册中心的时间误差秒数<br />如果时间误差超过配置秒数则作业启动时将抛异常<br />配置为-1表示不校验时间误差|
| failover | boolean | 否 | false | 是否开启失效转移<br />仅monitorExecution开启，失效转移才有效 |
| failover | boolean | 否 | false | 是否开启失效转移 |
| misfire | boolean | 否 | true | 是否开启错过任务重新执行 |
| job-sharding-strategy-class | String | 否 | | 作业分片策略实现类全路径<br />默认使用平均分配策略<br />详情参见：[作业分片策略](/02-guide/job-sharding-strategy)|
| description | String | 否 | | 作业描述信息 |
Expand All @@ -134,7 +134,7 @@ Spring命名空间与Java Code方式配置类似，大部分属性只是将命
| job-exception-handler | String | 否 | | 扩展异常处理类 |
| executor-service-handler | String | 否 | | 扩展作业处理线程池类 |
| reconcile-interval-minutes | int | 否 | 10 | 修复作业服务器不一致状态服务调度间隔时间，配置为小于1的任意值表示不执行修复<br />单位：分钟 |
| event-trace-rdb-data-source | String | 否 | | 作业事件追踪的数据源Bean引用 |
| event-trace-rdb-data-source | String | 否 | | 作业事件追踪的数据源Bean引用 |

#### job:dataflow命名空间属性详细说明

Expand Down
Loading

0 comments on commit 9fb314b

Please sign in to comment.