You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/04/05 17:31:47 UTC
[flink] branch master updated (fc1df95 -> bb46756)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fc1df95 [FLINK-16098][docs-zh] Translate "Overview" page of "Hive Integration" into Chinese
add bb46756 [FLINK-16913] Migrate StateBackends to use ReadableConfig instead of Configuration
No new revisions were added by this update.
Summary of changes:
.../generated/rocks_db_configuration.html | 4 +-
.../generated/state_backend_rocksdb_section.html | 4 +-
.../ReadableConfigToConfigurationAdapter.java | 328 ---------------------
.../runtime/state/ConfigurableStateBackend.java | 4 +-
.../flink/runtime/state/StateBackendFactory.java | 4 +-
.../flink/runtime/state/StateBackendLoader.java | 11 +-
.../state/filesystem/AbstractFileStateBackend.java | 8 +-
.../runtime/state/filesystem/FsStateBackend.java | 14 +-
.../state/filesystem/FsStateBackendFactory.java | 6 +-
.../runtime/state/memory/MemoryStateBackend.java | 10 +-
.../state/memory/MemoryStateBackendFactory.java | 4 +-
.../runtime/state/StateBackendLoadingTest.java | 3 +-
.../state/testutils/BackendForTestStream.java | 4 +-
.../state/ConfigurableOptionsFactory.java | 4 +-
.../state/ConfigurableRocksDBOptionsFactory.java | 4 +-
.../state/DefaultConfigurableOptionsFactory.java | 6 +-
.../state/RocksDBMemoryConfiguration.java | 10 +-
.../state/RocksDBNativeMetricOptions.java | 56 ++--
.../contrib/streaming/state/RocksDBOptions.java | 6 +-
.../state/RocksDBOptionsFactoryAdapter.java | 4 +-
.../streaming/state/RocksDBStateBackend.java | 25 +-
.../state/RocksDBStateBackendFactory.java | 6 +-
.../streaming/state/RocksDBAsyncSnapshotTest.java | 2 +-
.../RocksDBOptionsFactoryCompatibilityTest.java | 3 +-
.../state/RocksDBStateBackendConfigTest.java | 24 +-
.../state/RocksDBStateBackendMigrationTest.java | 4 +-
.../streaming/state/RocksDBStateBackendTest.java | 4 +-
.../environment/StreamExecutionEnvironment.java | 3 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 5 +-
.../tasks/TaskCheckpointingBehaviourTest.java | 5 +-
.../EventTimeWindowCheckpointingITCase.java | 4 +-
31 files changed, 126 insertions(+), 453 deletions(-)
delete mode 100644 flink-core/src/main/java/org/apache/flink/configuration/ReadableConfigToConfigurationAdapter.java