The GitHub Actions job "CI" on fluss.git/agg-mode has failed. Run started by GitHub user platinumhamburg (triggered by platinumhamburg).
Head commit for run: cda06974187239bb82af21d6af40abd415db5604 / ocean.wy <[email protected]> [FLUSS] Add AggMode support for undo recovery in aggregation tables This commit introduces AggMode (Aggregation Mode) to control how the server handles data aggregation when writing to tables with aggregation merge engine. Key changes: 1. New AggMode enum with three modes: - AGGREGATE (default): Data is aggregated through server-side merge engine - OVERWRITE: Bypass merge engine, directly replace values (for undo recovery) - LOCAL_AGGREGATE: Reserved for future client-side pre-aggregation 2. Client-side changes: - Upsert interface: Added aggregationMode(AggMode) method for fluent API - UpsertWriterImpl: Propagates aggMode through WriteRecord - KvWriteBatch: Validates aggMode consistency within batch - ClientRpcMessageUtils: Validates aggMode consistency across batches - WriteRecord: Added aggMode field for upsert/delete operations 3. Server-side changes: - KvTablet: Pre-creates overwriteRowMerger for OVERWRITE mode - putAsLeader(): Selects appropriate RowMerger based on aggMode - Replica/ReplicaManager: Propagates aggMode through call chain - TabletService: Extracts aggMode from PutKvRequest 4. Protocol changes: - FlussApi.proto: Added optional agg_mode field to PutKvRequest 5. Test coverage: - KvTabletAggModeTest: 9 tests covering OVERWRITE mode scenarios - KvWriteBatchTest: 3 tests for aggMode consistency validation - ClientRpcMessageUtilsTest: 4 tests for multi-batch aggMode validation This feature enables Flink connector to perform undo recovery by restoring exact historical values during checkpoint failover, bypassing the merge engine. Report URL: https://github.com/apache/fluss/actions/runs/21395501084 With regards, GitHub Actions via GitBox
