You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2020/06/16 08:32:37 UTC
[flink] branch master updated (3792f8f -> f125062)
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 3792f8f [FLINK-17666][table-planner-blink] Insert into partitioned table can fail with select *
add 8ca388c [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse
add f125062 [FLINK-17800][roksdb] 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 | 147 +++++++++++++++++++++
.../contrib/streaming/state/RocksDBTestUtils.java | 21 +++
...RocksKeyGroupsRocksSingleStateIteratorTest.java | 6 +-
.../state/benchmark/RocksDBPerformanceTest.java | 3 +-
19 files changed, 327 insertions(+), 53 deletions(-)
create mode 100644 flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateMisuseOptionTest.java