From 27d2614a14e63158e66bc17297eea33c87fe4262 Mon Sep 17 00:00:00 2001 From: lincoln lee Date: Wed, 9 Jul 2025 22:18:11 +0800 Subject: [PATCH 1/2] [hotfix][docs] Make timeout param of async i/o more clearer --- docs/content.zh/docs/dev/datastream/operators/asyncio.md | 3 ++- docs/content/docs/dev/datastream/operators/asyncio.md | 5 +++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/docs/content.zh/docs/dev/datastream/operators/asyncio.md b/docs/content.zh/docs/dev/datastream/operators/asyncio.md index ebdb93a550a74..e30344fbdf180 100644 --- a/docs/content.zh/docs/dev/datastream/operators/asyncio.md +++ b/docs/content.zh/docs/dev/datastream/operators/asyncio.md @@ -137,7 +137,8 @@ DataStream> resultStream = 下面两个参数控制异步操作： - - **Timeout**： 超时参数定义了异步操作执行多久未完成、最终认定为失败的时长，如果启用重试，则可能包括多个重试请求。 它可以防止一直等待得不到响应的请求。 + - **Timeout**： 超时定义了从首次调用到异步操作最终完成的最大持续时间。 + 此持续时间可能包括多次重试尝试（如果启用了重试）并确定操作最终被视为失败的时间点。 它可以防止一直等待得不到响应的请求。 - **Capacity**： 容量参数定义了可以同时进行的异步请求数。 即使异步 I/O 通常带来更高的吞吐量，执行异步 I/O 操作的算子仍然可能成为流处理的瓶颈。 限制并发请求的数量可以确保算子不会持续累积待处理的请求进而造成积压，而是在容量耗尽时触发反压。 diff --git a/docs/content/docs/dev/datastream/operators/asyncio.md b/docs/content/docs/dev/datastream/operators/asyncio.md index f09f507aedcee..395b3ff56a10b 100644 --- a/docs/content/docs/dev/datastream/operators/asyncio.md +++ b/docs/content/docs/dev/datastream/operators/asyncio.md @@ -152,8 +152,9 @@ All subsequent `complete` calls will be ignored. The following three parameters control the asynchronous operations: - - **Timeout**: The timeout defines how long an asynchronous operation take before it is finally considered failed, - may include multiple retry requests if retry enabled. This parameter guards against dead/failed requests. + - **Timeout**: The timeout defines the maximum duration from the first invocation to the final completion of an asynchronous operation, + This duration may include multiple retry attempts (if retries are enabled) and determines when the operation is ultimately considered failed. + This parameter guards against dead/failed requests. - **Capacity**: This parameter defines how many asynchronous requests may be in progress at the same time. Even though the async I/O approach leads typically to much better throughput, the operator can still be the bottleneck in From a31f5bc5e2f0670b689efcfc2f3deb10c0d68dc9 Mon Sep 17 00:00:00 2001 From: lincoln lee Date: Thu, 10 Jul 2025 20:57:22 +0800 Subject: [PATCH 2/2] address comment --- docs/content/docs/dev/datastream/operators/asyncio.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/content/docs/dev/datastream/operators/asyncio.md b/docs/content/docs/dev/datastream/operators/asyncio.md index 395b3ff56a10b..b587350ef3a34 100644 --- a/docs/content/docs/dev/datastream/operators/asyncio.md +++ b/docs/content/docs/dev/datastream/operators/asyncio.md @@ -153,7 +153,7 @@ All subsequent `complete` calls will be ignored. The following three parameters control the asynchronous operations: - **Timeout**: The timeout defines the maximum duration from the first invocation to the final completion of an asynchronous operation, - This duration may include multiple retry attempts (if retries are enabled) and determines when the operation is ultimately considered failed. + This duration may include multiple retry attempts (if retries are enabled) and determines when the operation is ultimately considered complete. This parameter guards against dead/failed requests. - **Capacity**: This parameter defines how many asynchronous requests may be in progress at the same time.