The GitHub Actions job "CI" on fluss.git/producer has failed. Run started by GitHub user platinumhamburg (triggered by platinumhamburg).
Head commit for run: 478e8ec58473ed8a1f820ff9c97ac9a7c87d21a7 / ocean.wy <[email protected]> [FLUSS] Add Producer Offset Snapshot for Exactly-Once Semantics This commit introduces the Producer Offset Snapshot feature to support exactly-once semantics in Fluss. The feature allows producers (e.g., Flink jobs) to register their offset snapshots for recovery purposes. Main changes: - Add ProducerSnapshotManager for lifecycle management of producer snapshots - Add ProducerSnapshotStore for low-level storage operations (ZK + remote FS) - Add Admin APIs: registerProducerOffsets, getProducerOffsets, deleteProducerOffsets - Add RetryUtils for IO operations with exponential backoff - Add configuration options for snapshot TTL and cleanup interval Code quality improvements: - Remove ProducerSnapshotResultCodes class, use RegisterResult enum directly - Fix RetryUtils interrupt handling to preserve thread interrupt status - Add comprehensive tests for ProducerSnapshotManager including concurrency tests - Add interrupt handling tests for RetryUtils Report URL: https://github.com/apache/fluss/actions/runs/21289447792 With regards, GitHub Actions via GitBox
