Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -1124,8 +1124,8 @@ private DataNodeMiscMessages() {}
public static final String MISC_LOG_PARTITION_TABLE_RECOVER_WORKER_NUM_SHOULD_BE_GREATER_THAN_74A2512B =
"partition_table_recover_worker_num should be greater than 0, but current value is {}, "
+ "ignore that and use the default value {}";
public static final String MISC_LOG_PARTITION_TABLE_RECOVER_MAX_READ_MEGABYTES_PER_SECOND_SHOULD_42BCDFBC =
"partition_table_recover_max_read_megabytes_per_second should be greater than 0, but current "
public static final String MISC_LOG_PARTITION_TABLE_RECOVER_MAX_READ_MB_PER_SEC_SHOULD_42BCDFBC =
"partition_table_recover_max_read_mb_per_sec should be greater than 0, but current "
+ "value is {}, ignore that and use the default value {}";
public static final String MISC_LOG_THE_THROTTLE_THRESHOLD_PARAMS_IS_DEPRECATED_PLEASE_USE_AA0E8EC7 =
"The throttle threshold params: {} is deprecated, please use {}";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1163,12 +1163,11 @@ public void loadProperties(TrimProperties properties) throws BadNodeUrlException
int partitionTableRecoverMaxReadMBsPerSecond =
Integer.parseInt(
properties.getProperty(
"partition_table_recover_max_read_megabytes_per_second",
"partition_table_recover_max_read_mb_per_sec",
String.valueOf(conf.getPartitionTableRecoverMaxReadMBsPerSecond())));
if (partitionTableRecoverMaxReadMBsPerSecond <= 0) {
LOGGER.warn(
DataNodeMiscMessages
.MISC_LOG_PARTITION_TABLE_RECOVER_MAX_READ_MEGABYTES_PER_SECOND_SHOULD_42BCDFBC,
DataNodeMiscMessages.MISC_LOG_PARTITION_TABLE_RECOVER_MAX_READ_MB_PER_SEC_SHOULD_42BCDFBC,
partitionTableRecoverMaxReadMBsPerSecond,
conf.getPartitionTableRecoverMaxReadMBsPerSecond());
partitionTableRecoverMaxReadMBsPerSecond = conf.getPartitionTableRecoverMaxReadMBsPerSecond();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -794,7 +794,7 @@ partition_table_recover_worker_num=10
# Limit the number of bytes read per second from a file, the unit is MB
# effectiveMode: restart
# Datatype: Integer
partition_table_recover_max_read_megabytes_per_second=10
partition_table_recover_max_read_mb_per_sec=10

####################
### Memory Control Configuration
Expand Down