diff --git a/docs/_includes/generated/rocks_db_configurable_configuration.html b/docs/_includes/generated/rocks_db_configurable_configuration.html index 638a3a5574763..fa0e0ff0dd04b 100644 --- a/docs/_includes/generated/rocks_db_configurable_configuration.html +++ b/docs/_includes/generated/rocks_db_configurable_configuration.html @@ -40,12 +40,12 @@
state.backend.rocksdb.files.open
(none) - The maximum number of open files that can be used by the DB, '-1' means no limit. RocksDB has default configuration as '5000'. + The maximum number of open files (per TaskManager) that can be used by the DB, '-1' means no limit. RocksDB has default configuration as '5000'.
state.backend.rocksdb.thread.num
(none) - The maximum number of concurrent background flush and compaction jobs. RocksDB has default configuration as '1'. + The maximum number of concurrent background flush and compaction jobs (per TaskManager). RocksDB has default configuration as '1'.
state.backend.rocksdb.writebuffer.count
diff --git a/docs/_includes/generated/rocks_db_configuration.html b/docs/_includes/generated/rocks_db_configuration.html index 88e8c466f92b5..f9a6d95f0f674 100644 --- a/docs/_includes/generated/rocks_db_configuration.html +++ b/docs/_includes/generated/rocks_db_configuration.html @@ -10,7 +10,7 @@
state.backend.rocksdb.checkpoint.transfer.thread.num
1 - The number of threads used to transfer (download and upload) files in RocksDBStateBackend. + The number of threads (per stateful operator) used to transfer (download and upload) files in RocksDBStateBackend.
state.backend.rocksdb.localdir
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java index 089f08cd669d3..261e5f020b816 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java @@ -46,13 +46,13 @@ public class RocksDBConfigurableOptions implements Serializable { public static final ConfigOption MAX_BACKGROUND_THREADS = key("state.backend.rocksdb.thread.num") .noDefaultValue() - .withDescription("The maximum number of concurrent background flush and compaction jobs. " + + .withDescription("The maximum number of concurrent background flush and compaction jobs (per TaskManager). " + "RocksDB has default configuration as '1'."); public static final ConfigOption MAX_OPEN_FILES = key("state.backend.rocksdb.files.open") .noDefaultValue() - .withDescription("The maximum number of open files that can be used by the DB, '-1' means no limit. " + + .withDescription("The maximum number of open files (per TaskManager) that can be used by the DB, '-1' means no limit. " + "RocksDB has default configuration as '5000'."); //-------------------------------------------------------------------------- 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 8fa497b47d8e1..8ffd1423d5a8e 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 @@ -56,7 +56,7 @@ public class RocksDBOptions { public static final ConfigOption CHECKPOINT_TRANSFER_THREAD_NUM = ConfigOptions .key("state.backend.rocksdb.checkpoint.transfer.thread.num") .defaultValue(1) - .withDescription("The number of threads used to transfer (download and upload) files in RocksDBStateBackend."); + .withDescription("The number of threads (per stateful operator) used to transfer (download and upload) files in RocksDBStateBackend."); /** This determines if compaction filter to cleanup state with TTL is enabled. */ public static final ConfigOption TTL_COMPACT_FILTER_ENABLED = ConfigOptions