Skip to content

Commit

Permalink
update rate limit key name
Browse files Browse the repository at this point in the history
  • Loading branch information
gaoyan1998 committed Sep 19, 2024
1 parent 94bd9fa commit fd932fa
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 13 deletions.
12 changes: 6 additions & 6 deletions docs/content.zh/docs/core-concept/data-pipeline.md
Original file line number Diff line number Diff line change
Expand Up @@ -111,9 +111,9 @@ We could use following yaml file to define a complicated Data Pipeline describin
# Pipeline Configurations
The following config options of Data Pipeline level are supported:
| parameter | meaning | optional/required |
|-----------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
| local-time-zone | The local time zone defines current session time zone id. | optional |
| rate.limit | 限制数据源读取速率,防止下游压力过大。单位为条/秒。(目前仅支持mysql数据源) | 可选 |
| parameter | meaning | optional/required |
|-------------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
| local-time-zone | The local time zone defines current session time zone id. | optional |
| source-rate-limit | 限制数据源读取速率,防止下游压力过大。单位为条/秒。(目前仅支持mysql数据源) | 可选 |
12 changes: 6 additions & 6 deletions docs/content/docs/core-concept/data-pipeline.md
Original file line number Diff line number Diff line change
Expand Up @@ -129,9 +129,9 @@ We could use following yaml file to define a complicated Data Pipeline describin
# Pipeline Configurations
The following config options of Data Pipeline level are supported:
| parameter | meaning | optional/required |
|-----------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
| local-time-zone | The local time zone defines current session time zone id. | optional |
| rate.limit | Limit the reading rate of data sources. (Only the MySQL data source is supported.) | optional |
| parameter | meaning | optional/required |
|-------------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
| local-time-zone | The local time zone defines current session time zone id. | optional |
| source-rate-limit | Limit the reading rate of data sources. (Only the MySQL data source is supported.) | optional |
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public class PipelineOptions {
.withDescription("The name of the pipeline");

public static final ConfigOption<Double> RATE_LIMIT =
ConfigOptions.key("rate.limit")
ConfigOptions.key("source-rate-limit")
.doubleType()
.defaultValue(0d)
.withDescription(
Expand Down

0 comments on commit fd932fa

Please sign in to comment.