[jira] [Created] (FLINK-36216) RocksDB: Compaction sees out-of-order keys

["Robert Metzger (Jira)" <ji...@apache.org>]

Robert Metzger created FLINK-36216:
--------------------------------------

             Summary: RocksDB: Compaction sees out-of-order keys
                 Key: FLINK-36216
                 URL: https://issues.apache.org/jira/browse/FLINK-36216
             Project: Flink
          Issue Type: Bug
          Components: Runtime / State Backends
    Affects Versions: 1.19.0
            Reporter: Robert Metzger


{code}
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)
{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)