diff --git a/common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala b/common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala index d0ea3afa7..17fe8e8d7 100644 --- a/common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala +++ b/common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala @@ -2600,7 +2600,7 @@ object CelebornConf extends Logging { "When set to 1, Netty's direct memory is close to disk buffer, but performance " + "might decrease due to frequent memory copy during compaction.") .intConf - .createWithDefault(16) + .createWithDefault(128) val WORKER_FETCH_HEARTBEAT_ENABLED: ConfigEntry[Boolean] = buildConf("celeborn.worker.fetch.heartbeat.enabled")