[FLINK-21694][rocksdb] Increase default value for 'state.backend.rock…

…sdb.checkpoint.transfer.thread.num'
bbejeck · Apr 20, 2021 · 861a46e · 861a46e
1 parent 8256213
commit 861a46e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java b/...ackend-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.");