fix config

zhengchenyu · Sep 10, 2024 · abb370c · abb370c
1 parent c83b3f9
commit abb370c
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java b/common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java
@@ -254,26 +254,26 @@ public class RssClientConf {
  "Whether to support rss client block send failure retry, default value is false.");
 
  public static final ConfigOption<Integer> RSS_CLIENT_REMOTE_MERGE_FETCH_INIT_SLEEP_MS =
- ConfigOptions.key("rss.client.remote.merge.fetch.init.sleep.ms")
+ ConfigOptions.key("rss.client.remote.merge.fetch.initSleepMs")
  .intType()
  .defaultValue(100)
  .withDescription("the init sleep ms for fetch remote merge records");
 
  public static final ConfigOption<Integer> RSS_CLIENT_REMOTE_MERGE_FETCH_MAX_SLEEP_MS =
- ConfigOptions.key("rss.client.remote.merge.fetch.max.sleep.ms")
+ ConfigOptions.key("rss.client.remote.merge.fetch.maxSleepMs")
  .intType()
  .defaultValue(5000)
  .withDescription("the max sleep ms for fetch remote merge records");
 
  public static final ConfigOption<Integer> RSS_CLIENT_REMOTE_MERGE_READER_MAX_BUFFER =
- ConfigOptions.key("rss.client.remote.merge.reader.max.buffer")
+ ConfigOptions.key("rss.client.remote.merge.reader.maxBuffer")
  .intType()
  .defaultValue(2)
  .withDescription(
  "the max size of buffer in queue for one partition when fetch remote merge records");
 
  public static final ConfigOption<Integer> RSS_CLIENT_REMOTE_MERGE_READER_MAX_RECORDS_PER_BUFFER =
- ConfigOptions.key("rss.client.remote.merge.reader.max.records.per.buffer")
+ ConfigOptions.key("rss.client.remote.merge.reader.maxRecordsPerBuffer")
  .intType()
  .defaultValue(500)
  .withDescription("the max size of records per buffer when fetch remote merge records");