yuxiqian commented on code in PR #3918: URL: https://github.com/apache/flink-cdc/pull/3918#discussion_r2609967041
########## docs/content.zh/docs/deployment/yarn.md: ########## @@ -147,19 +144,28 @@ Job Description: Sync MySQL Database to Doris 你可以通过 Flink Web UI 找到一个名为 `Sync MySQL Database to Doris` 的作业。 -# Yarn Application 模式 +## Yarn Application 模式 Yarn Application 模式是 Yarn 集群上运行 Flink 作业的推荐模式。对资源的管理和分配更加灵活，可以更好地利用集群资源。 -通过Cli将作业提交至 Flink Yarn Application 集群。 -```bash -cd /path/flink-cdc-* -./bin/flink-cdc.sh -t yarn-application -Dexecution.checkpointing.interval=2min mysql-to-doris.yaml +修改mysql-to-doris.yaml作业的运行方式为Yarn Application模式： +```yaml +... +pipeline: + name: Sync MySQL Database to Doris + parallelism: 2 + flink: + execution.target: yarn-application + execution.checkpointing.interval: 2min + #如果需要从savepoint恢复，则配置以下参数 + #execution.savepoint.path: hdfs:///flink/savepoint-1537 ``` -或者从savepoint恢复Flink-CDC作业： + +通过Cli将作业提交至 Flink Yarn Application 集群。 ```bash cd /path/flink-cdc-* -./bin/flink-cdc.sh -t yarn-application -s hdfs:///flink/savepoint-1537 -Dexecution.checkpointing.interval=2min mysql-to-doris.yaml Review Comment: +1 to keep CLI mode examples. Checkpoint path is not a static configuration and prone to change. Hard encoding it in YAML file is not better than dynamic CLI arguments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
