The GitHub Actions job "Check License" on fluss.git/retract has failed.
Run started by GitHub user platinumhamburg (triggered by platinumhamburg).

Head commit for run:
be4fd75e019dafa206d6b4fa3eefb222c4dc45bf / 白鵺 <[email protected]>
[server][client][flink] Add retract support for Aggregation Merge Engine

Introduce RETRACT_THEN_AGGREGATE merge mode that optimizes changelog from
4 records per key to 2 by pairing retract+upsert in a single batch.

Server:
- Add MergeMode.RETRACT_THEN_AGGREGATE with iterator-based look-ahead pairing
- Implement RowMerger.retract() for SUM, PRODUCT, LAST_VALUE, 
LAST_VALUE_IGNORE_NULLS
- Dynamic supportsRetract() check per FieldAggregator instead of hardcoded true

Client:
- Add UpsertWriter.retractThenUpsert() API for atomic paired writes
- Add RecordAccumulator.appendPair() with batch-split prevention guarantee
- Add WriterClient.sendPair() with exception-propagating callback

Flink:
- UpsertSinkWriter buffers UPDATE_BEFORE, pairs with UPDATE_AFTER via 
retractThenUpsert()
- Deep-copy InternalRow (GenericRow) and BinaryRow to handle mutable buffer 
reuse
- Early validation rejects non-retractable aggregation columns at sink 
initialization

Report URL: https://github.com/apache/fluss/actions/runs/23526670146

With regards,
GitHub Actions via GitBox

Reply via email to