You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2021/04/20 16:13:48 UTC

[flink] 02/02: [FLINK-21694][rocksdb] Increase default value for 'state.backend.rocksdb.checkpoint.transfer.thread.num'

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 <se...@apache.org>
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.");