This is an automated email from the ASF dual-hosted git repository.
liyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6227fff fixup! [FLINK-18349][docs] Add release notes for Flink 1.11
add 3516e37 [FLINK-17800][rocksdb] Ensure total order seek to avoid user
misuse
add 11d4513 [hot-fix][rocksdb] Ensure RocksDBKeyedStateBackend disposed
at RocksDBStateMisuseOptionTest
add 1718f50 [FLINK-17800][rocksdb] Support customized RocksDB write/read
options and use RocksDBResourceContainer to get them
No new revisions were added by this update.
Summary of changes:
.../state/RocksDBCachingPriorityQueueSet.java | 8 +-
.../state/RocksDBIncrementalCheckpointUtils.java | 4 +-
.../streaming/state/RocksDBKeyedStateBackend.java | 21 ++-
.../state/RocksDBKeyedStateBackendBuilder.java | 16 +--
.../contrib/streaming/state/RocksDBMapState.java | 6 +-
.../streaming/state/RocksDBOperationUtils.java | 15 +-
.../streaming/state/RocksDBOptionsFactory.java | 34 +++++
.../state/RocksDBPriorityQueueSetFactory.java | 9 +-
.../streaming/state/RocksDBResourceContainer.java | 34 +++++
.../RocksDBIncrementalRestoreOperation.java | 7 +-
...rtitionedPriorityQueueWithRocksDBStoreTest.java | 1 +
.../contrib/streaming/state/RocksDBResource.java | 4 +-
.../state/RocksDBResourceContainerTest.java | 14 ++
.../state/RocksDBRocksStateKeysIteratorTest.java | 2 +-
.../state/RocksDBStateBackendConfigTest.java | 28 +---
.../state/RocksDBStateMisuseOptionTest.java | 157 +++++++++++++++++++++
.../contrib/streaming/state/RocksDBTestUtils.java | 21 +++
...RocksKeyGroupsRocksSingleStateIteratorTest.java | 6 +-
.../state/benchmark/RocksDBPerformanceTest.java | 3 +-
19 files changed, 337 insertions(+), 53 deletions(-)
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateMisuseOptionTest.java
