haruki-830 commented on code in PR #4526: URL: https://github.com/apache/flink-cdc/pull/4526#discussion_r3986145390
##########
docs/content.zh/docs/core-concept/data-pipeline.md:
##########
@@ -125,5 +125,11 @@ under the License.
| `operator.uid.prefix` | Pipeline 中算子 UID 的前缀。如果不设置，Flink 会为每个算子生成唯一的
UID。 建议设置这个参数以提供稳定和可识别的算子 ID，这有助于有状态升级、问题排查和在 Flink UI 上的诊断。
| optional |
| `sink.partitioning.strategy` | Sink
写入数据时使用的分区策略。数据类型：String。默认值：`SINK_DEFINED`。备注：可配置的值如下：`SINK_DEFINED`：使用 Sink
定义的分区策略；`PRIMARY_KEY`：按表 ID 和主键分区；`TABLE_ID`：仅按表 ID 分区。
| optional |
| `transform.decimal.precision.mode` | transform 表达式求值中 DECIMAL
类型的最大精度模式。可选值：`UP_TO_19`（默认，使用 Calcite 默认类型系统）或 `UP_TO_38`（允许 DECIMAL 精度最高为 38
位）。
| optional |
+| `transform.async-execution.enabled` | 是否为 PostTransform 开启有序异步执行，默认值为
`false`。
| optional |
+| `transform.async-execution.timeout` | 有序异步执行中每个 PostTransform 事件的超时时间，默认值为 5
分钟。
| optional |
+| `transform.async-execution.capacity` | 异步执行中最多允许同时处理的 PostTransform 事件数，默认值为
100。
| optional |
+| `transform.async-execution.worker-threads` | 每个异步 PostTransform
任务使用的工作线程数，默认值为 16。
| optional |
+
+异步 PostTransform 适用于 AI 模型调用等 I/O 密集型表达式。DataChangeEvent 可能并发调用 UDF 和 AI
模型客户端，但输出和所有 SchemaChangeEvent 仍保持有序，因此 UDF 和 AI 模型客户端实现必须是线程安全的。为保证 schema
状态一致，checkpoint 或 savepoint 前会等待尚未完成的异步请求，长时间运行的请求可能会延长 checkpoint 时间。savepoint
只支持在并行度不变时恢复，并且不能在从已有 savepoint 恢复时开启或关闭此选项。
Review Comment:
The documentation now marks async transform as experimental and unstable.
--
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]
