This is an automated email from the ASF dual-hosted git repository.
rexxiong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from 497bfdf5d [CELEBORN-1640] NettyMemoryMetrics supports numHeapArenas,
numDirectArenas, tinyCacheSize, smallCacheSize, normalCacheSize,
numThreadLocalCaches and chunkSize
add 7c9a008a1 [CELEBORN-1487][PHASE2] CongestionController support dynamic
config
No new revisions were added by this update.
Summary of changes:
.../org/apache/celeborn/common/CelebornConf.scala | 36 +++---
.../celeborn/common/quota/UserTrafficQuota.scala} | 6 +-
.../common/quota/WorkerTrafficQuota.scala} | 8 +-
docs/configuration/worker.md | 12 +-
.../service/config/BaseConfigServiceImpl.java | 16 +++
.../common/service/config/ConfigService.java | 7 ++
.../common/service/config/DynamicConfig.java | 40 +++++++
.../congestcontrol/CongestionController.java | 127 ++++++++++++---------
.../UserCongestionControlContext.java | 13 +++
.../celeborn/service/deploy/worker/Worker.scala | 19 +--
.../congestcontrol/TestCongestionController.java | 119 ++++++++++++++++---
.../src/test/resources/dynamicConfig.yaml | 4 +-
.../src/test/resources/dynamicConfig_2.yaml | 17 ++-
13 files changed, 299 insertions(+), 125 deletions(-)
copy common/src/main/{java/org/apache/celeborn/common/meta/FileMeta.java =>
scala/org/apache/celeborn/common/quota/UserTrafficQuota.scala} (84%)
copy common/src/main/{java/org/apache/celeborn/common/meta/FileMeta.java =>
scala/org/apache/celeborn/common/quota/WorkerTrafficQuota.scala} (78%)
copy service/src/test/resources/dynamicConfig_2.yaml =>
worker/src/test/resources/dynamicConfig.yaml (83%)
copy master/src/test/resources/dynamicConfig-quota.yaml =>
worker/src/test/resources/dynamicConfig_2.yaml (64%)
