[FLINK-36216] RocksDB: Compaction sees out-of-order keys

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.19.0
• Component/s: Runtime / State Backends
• Assignee: Unassigned
• Reporter: Robert Metzger
• Created: 04/Sep/24 12:46
• Updated: 04/Sep/24 13:20

Description

org.rocksdb.RocksDBException: Compaction sees out-of-order keys.
	at org.rocksdb.RocksDB.put(Native Method)
	at org.rocksdb.RocksDB.put(RocksDB.java:955)
	at org.apache.flink.contrib.streaming.state.RocksDBMapState.put(RocksDBMapState.java:139)
	at org.apache.flink.table.runtime.dataview.StateMapView$StateMapViewWithKeysNullable.put(StateMapView.java:168)
	at org.apache.flink.table.runtime.dataview.StateMapView$NamespacedStateMapViewWithKeysNullable.put(StateMapView.java:392)
	at GlobalWindowAggsHandler$473.merge_split229(Unknown Source)
	at GlobalWindowAggsHandler$473.merge(Unknown Source)
	at org.apache.flink.table.runtime.operators.aggregate.window.combines.GlobalAggCombiner.combineAccumulator(GlobalAggCombiner.java:99)
	at org.apache.flink.table.runtime.operators.aggregate.window.combines.GlobalAggCombiner.combine(GlobalAggCombiner.java:85)
	at org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer.flush(RecordsWindowBuffer.java:112)