[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator#27358

Open

featzhang wants to merge 19 commits intoapache:masterfrom

featzhang:FLINK-38825-metric

Commits on Mar 31, 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] Fix test failures by setting expected external failure cause in MockEnvironment
featzhang
committed
[FLINK-38825] Fix testStrictOrderingGuarantee test timeout issue
featzhang
committed
[FLINK-38341][configuration] Introduce the rescale history configuration option.

RocMarshal
authored and
featzhang
committed
[FLINK-38343][runtime] Support store rescale history with statistics by ExecutionGraphInfo.

RocMarshal
authored and
featzhang
committed
[FLINK-39358][table] Constraint and watermark should stay while CoA MT if there is no explicit change with schema or constraint definition

snuyanzin
authored and
featzhang
committed
[FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData

ldadima
authored and
featzhang
committed
[FLINK-39348][table] Add `Interval` to reuse code for `FRESHNESS` and `START MODE`

snuyanzin
authored and
featzhang
committed
[FLINK-38861][docs] Update documentation to cover new `CREATE`/`ALTER` operations for `MATERIALIZED TABLE`s

snuyanzin
authored and
featzhang
committed
[FLINK-39360][table] `LIKE` clause doesn't support some patterns

snuyanzin
authored and
featzhang
committed
[FLINK-39302][table] Support `SHOW CREATE OR ALTER MATERIALIZED TABLE`

snuyanzin
authored and
featzhang
committed
[hotfix] Rename isUnalignedDuringRecoveryEnabled to isCheckpointingDuringRecoveryEnabled

1996fanrui
authored and
featzhang
committed
[FLINK-38930][checkpoint] Filtering record before processing without spilling strategy

1996fanrui
authored and
featzhang
committed
[FLINK-38930][checkpoint] Use heap buffer fallback to avoid deadlock during recovery

1996fanrui
authored and
featzhang
committed
[FLINK-39371][table] `CurrentDatabase` fails for some patterns

snuyanzin
authored and
featzhang
committed
[FLINK-38825][streaming] Fix testStrictOrderingGuarantee timeout issue
featzhang
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator#27358

[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator#27358
featzhang wants to merge 19 commits intoapache:masterfrom
featzhang:FLINK-38825-metric

Commits on Mar 31, 2026

[FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator

[FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator

[FLINK-38825] Add ordered async batch support for AsyncBatchWaitOperator

[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator

[FLINK-38825][streaming] Fix test failures by setting expected external failure cause in MockEnvironment

[FLINK-38825] Fix testStrictOrderingGuarantee test timeout issue

[FLINK-38341][configuration] Introduce the rescale history configuration option.

[FLINK-38343][runtime] Support store rescale history with statistics by ExecutionGraphInfo.

[FLINK-39358][table] Constraint and watermark should stay while CoA MT if there is no explicit change with schema or constraint definition

[FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData

[FLINK-39348][table] Add `Interval` to reuse code for `FRESHNESS` and `START MODE`

[FLINK-38861][docs] Update documentation to cover new `CREATE`/`ALTER` operations for `MATERIALIZED TABLE`s

[FLINK-39360][table] `LIKE` clause doesn't support some patterns

[FLINK-39302][table] Support `SHOW CREATE OR ALTER MATERIALIZED TABLE`

[hotfix] Rename isUnalignedDuringRecoveryEnabled to isCheckpointingDuringRecoveryEnabled

[FLINK-38930][checkpoint] Filtering record before processing without spilling strategy

[FLINK-38930][checkpoint] Use heap buffer fallback to avoid deadlock during recovery

[FLINK-39371][table] `CurrentDatabase` fails for some patterns

[FLINK-38825][streaming] Fix testStrictOrderingGuarantee timeout issue