This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6dd510e [FLINK-15254][sql cli][module] modules in SQL CLI yaml should
preserve order
new 13c577f [FLINK-14926][state-backend-rocksdb] Ensure that RocksObjects
are always closed on backend disposal
new e5e199f [hotfix][tests] Remove unnecessary temp directory handling
new 1917cb3 [hotfix][tests Use assumptions rather than manual checks in
RocksDBStateBackendConfigTest to report skipped tests properly
new 4dd1d71 [hotfix][tests] Ensure RocksDB native library is loaded into
temp directory
new f8471a8 [FLINK-15177][state-backend-rocksdb] Migrate RocksDB
Configurable Options to new type safe config options
new 3695264 [hotfix][state-backend-rocksdb] Some minor style cleanups in
RocksDBResourceContainer
new 5326730 [FLINK-14926][state-backend-rocksdb] (follow-up) Make
RocksDBResourceContainer immutable
new 386dad8 [FLINK-14926][state-backend-rocksdb] (follow-up) Simplify
test to rely on RocksDBResourceContainer for cleanup of native handles
new f5fa21b [FLINK-14926][state-backend-rocksdb] (follow-up) Avoid
exposing handles that will not be closed from RocksDBStateBackend
new 6f777d5 [FLINK-14926][state-backend-rocksdb] (follow-up) Simplify
collecton the option objects to close
new e94bf2f [FLINK-14926][state-backend-rocksdb] (follow-up) Replace
OptionsFactory for RocksDBOptionsFactory
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../state/ConfigurableOptionsFactory.java | 2 +-
...java => ConfigurableRocksDBOptionsFactory.java} | 4 +-
.../state/DefaultConfigurableOptionsFactory.java | 105 +++++++---------
.../contrib/streaming/state/OptionsFactory.java | 21 +---
.../contrib/streaming/state/PredefinedOptions.java | 48 ++++++--
.../state/RocksDBConfigurableOptions.java | 40 ++++--
.../streaming/state/RocksDBKeyedStateBackend.java | 11 +-
.../state/RocksDBKeyedStateBackendBuilder.java | 23 ++--
...ionsFactory.java => RocksDBOptionsFactory.java} | 49 ++++++--
.../state/RocksDBOptionsFactoryAdapter.java | 75 ++++++++++++
.../streaming/state/RocksDBResourceContainer.java | 135 +++++++++++++++++++++
.../streaming/state/RocksDBStateBackend.java | 130 ++++++++++----------
.../RocksDBOptionsFactoryCompatibilityTest.java | 88 ++++++++++++++
.../contrib/streaming/state/RocksDBResource.java | 26 ++--
.../state/RocksDBResourceContainerTest.java | 132 ++++++++++++++++++++
.../state/RocksDBStateBackendConfigTest.java | 134 +++++++++-----------
.../streaming/state/RocksDBStateBackendTest.java | 27 ++---
.../contrib/streaming/state/RocksDBTestUtils.java | 13 +-
18 files changed, 757 insertions(+), 306 deletions(-)
copy
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/{ConfigurableOptionsFactory.java
=> ConfigurableRocksDBOptionsFactory.java} (91%)
copy
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/{OptionsFactory.java
=> RocksDBOptionsFactory.java} (62%)
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptionsFactoryAdapter.java
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBOptionsFactoryCompatibilityTest.java
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainerTest.java
