The GitHub Actions job "Check License" on fluss.git/undoinfra has succeeded. Run started by GitHub user platinumhamburg (triggered by platinumhamburg).
Head commit for run: 899db39356de98c0b84104e3246af2442ac910fe / ocean.wy <[email protected]> Add undo recovery support for aggregation tables This PR introduces the undo recovery mechanism for Flink sink writer to handle failure recovery scenarios with aggregation merge engine tables. Key components: - ByteArrayWrapper: Utility class for using byte arrays as map keys - UndoComputer: Computes undo operations by comparing checkpoint state with current log records, supporting both full row and partial update modes - UndoRecoveryExecutor: Executes undo operations using UpsertWriter - UndoRecoveryCoordinator: Coordinates the recovery process across buckets, managing log scanning, undo computation, and execution - BucketRecoveryContext: Holds per-bucket recovery state The undo recovery works by: 1. Scanning log records from checkpoint offset to current end offset 2. Computing inverse operations for uncommitted records 3. Executing undo operations to restore table state For partial update mode, INSERT records require full row deletion (not partial column deletion), which is handled by using a separate delete writer with null target columns. Report URL: https://github.com/apache/fluss/actions/runs/21576565803 With regards, GitHub Actions via GitBox
