diff options
| author | doufenghu <[email protected]> | 2024-04-02 17:36:46 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-04-02 17:36:46 +0800 |
| commit | 95bcb7db323b12d7e7f864dff615d73622d7e688 (patch) | |
| tree | 919b582cbcefb9304004444fda1d350a3041a2f5 /docs | |
| parent | 80e93523eb12f986acac73a81f2614516c718a5e (diff) | |
[Feature][Tests] add Kafka Container for unit test.
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/env-config.md | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/docs/env-config.md b/docs/env-config.md index 3e91f3e..e29acb0 100644 --- a/docs/env-config.md +++ b/docs/env-config.md @@ -44,12 +44,18 @@ Specify a list of classpath URLs via `pipeline.classpaths`, The classpaths are s You can directly use the flink parameter by prefixing `flink.`, such as `flink.execution.buffer-timeout`, `flink.object-reuse`, etc. More details can be found in the official [flink documentation](https://flink.apache.org/). Of course, you can use groot stream parameter, here are some parameter names corresponding to the names in Flink. -| Groot Stream | Flink | -|--------------------------|--------------------------------| -| execution.buffer-timeout | flink.execution.buffer-timeout | -| pipeline.object-reuse | flink.object-reuse | -| pipeline.max-parallelism | flink.pipeline.max-parallelism | -| ... | ... | +| Groot Stream | Flink | +|----------------------------------------|---------------------------------------------------------------| +| execution.buffer-timeout | flink.execution.buffer-timeout | +| pipeline.object-reuse | flink.object-reuse | +| pipeline.max-parallelism | flink.pipeline.max-parallelism | +| execution.restart.strategy | flink.restart-strategy | +| execution.restart.attempts | flink.restart-strategy.fixed-delay.attempts | +| execution.restart.delayBetweenAttempts | flink.restart-strategy.fixed-delay.delay | +| execution.restart.failure-rate | flink.restart-strategy.failure-rate.max-failures-per-interval | +| execution.restart.failureInterval | flink.restart-strategy.failure-rate.failure-rate-interval | +| execution.restart.delayInterval | flink.restart-strategy.failure-rate.delay | +| ... | ... | |