[FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator#27359

Open

featzhang wants to merge 7 commits intoapache:masterfrom

featzhang:FLINK-38825-retry-timeout-strategy

Commits on Apr 25, 2026

[FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator

averyzhang
authored and
featzhang
committed
[FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator

averyzhang
authored and
featzhang
committed
[FLINK-38825] Add ordered async batch support for AsyncBatchWaitOperator

averyzhang
authored and
featzhang
committed
[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator

averyzhang
authored and
featzhang
committed
[FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator

averyzhang
authored and
featzhang
committed
[FLINK-38825][streaming] Remove deprecated YieldingOperatorFactory usage
featzhang
committed

Commits on Apr 26, 2026

Add @PublicEvolving annotation to TimeoutBehavior enum
featzhang
committed