This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 285045673c6880cd01a6e0a7f55a542865339ace Author: Stephan Ewen <[email protected]> AuthorDate: Tue Apr 20 17:36:06 2021 +0200 [hotfix][rocksdb] Properly adjust RocksDB config options to new builder pattern --- .../java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java index 369e944..e3fecb2 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java @@ -38,6 +38,7 @@ public class RocksDBOptions { @Documentation.Section(Documentation.Sections.EXPERT_ROCKSDB) public static final ConfigOption<String> LOCAL_DIRECTORIES = ConfigOptions.key("state.backend.rocksdb.localdir") + .stringType() .noDefaultValue() .withDeprecatedKeys("state.backend.rocksdb.checkpointdir") .withDescription( @@ -61,6 +62,7 @@ public class RocksDBOptions { @Documentation.Section(Documentation.Sections.EXPERT_ROCKSDB) public static final ConfigOption<Integer> CHECKPOINT_TRANSFER_THREAD_NUM = ConfigOptions.key("state.backend.rocksdb.checkpoint.transfer.thread.num") + .intType() .defaultValue(1) .withDescription( "The number of threads (per stateful operator) used to transfer (download and upload) files in RocksDBStateBackend."); @@ -69,6 +71,7 @@ public class RocksDBOptions { @Documentation.Section(Documentation.Sections.EXPERT_ROCKSDB) public static final ConfigOption<String> PREDEFINED_OPTIONS = ConfigOptions.key("state.backend.rocksdb.predefined-options") + .stringType() .defaultValue(DEFAULT.name()) .withDescription( String.format( @@ -84,6 +87,7 @@ public class RocksDBOptions { @Documentation.Section(Documentation.Sections.EXPERT_ROCKSDB) public static final ConfigOption<String> OPTIONS_FACTORY = ConfigOptions.key("state.backend.rocksdb.options-factory") + .stringType() .defaultValue(DefaultConfigurableOptionsFactory.class.getName()) .withDescription( String.format(
