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 cc6a608d6be6281485253774a90c0ccce03ae948 Author: Stephan Ewen <[email protected]> AuthorDate: Tue Apr 20 17:38:04 2021 +0200 [FLINK-21694][rocksdb] Increase default value for 'state.backend.rocksdb.checkpoint.transfer.thread.num' --- .../java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 e3fecb2..206af0a 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 @@ -63,7 +63,7 @@ public class RocksDBOptions { public static final ConfigOption<Integer> CHECKPOINT_TRANSFER_THREAD_NUM = ConfigOptions.key("state.backend.rocksdb.checkpoint.transfer.thread.num") .intType() - .defaultValue(1) + .defaultValue(4) .withDescription( "The number of threads (per stateful operator) used to transfer (download and upload) files in RocksDBStateBackend.");
