Skip to content

Commit ef890c0

Browse files
committed
reponse to the reviewer
Signed-off-by: zhengyu <[email protected]>
1 parent 597e2dc commit ef890c0

File tree

5 files changed

+5
-5
lines changed

5 files changed

+5
-5
lines changed

be/src/cloud/cloud_internal_service.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ void CloudInternalServiceImpl::warm_up_rowset(google::protobuf::RpcController* c
455455
}
456456

457457
for (int64_t segment_id = 0; segment_id < rs_meta.num_segments(); segment_id++) {
458-
if (!config::enable_only_warm_up_idx) {
458+
if (!config::file_cache_enable_only_warm_up_idx) {
459459
auto segment_size = rs_meta.segment_file_size(segment_id);
460460
auto download_done = [=, version = rs_meta.version()](Status st) {
461461
DBUG_EXECUTE_IF("CloudInternalServiceImpl::warm_up_rowset.download_segment", {

be/src/cloud/cloud_tablet.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,7 @@ void CloudTablet::add_rowsets(std::vector<RowsetSharedPtr> to_add, bool version_
426426
}
427427
// clang-format off
428428
auto self = std::dynamic_pointer_cast<CloudTablet>(shared_from_this());
429-
if (!config::enable_only_warm_up_idx) {
429+
if (!config::file_cache_enable_only_warm_up_idx) {
430430
_engine.file_cache_block_downloader().submit_download_task(io::DownloadFileMeta {
431431
.path = storage_resource.value()->remote_segment_path(*rowset_meta, seg_id),
432432
.file_size = rs->rowset_meta()->segment_file_size(seg_id),

be/src/cloud/cloud_warm_up_manager.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ void CloudWarmUpManager::handle_jobs() {
249249
}
250250
for (int64_t seg_id = 0; seg_id < rs->num_segments(); seg_id++) {
251251
// 1st. download segment files
252-
if (!config::enable_only_warm_up_idx) {
252+
if (!config::file_cache_enable_only_warm_up_idx) {
253253
submit_download_tasks(
254254
storage_resource.value()->remote_segment_path(*rs, seg_id),
255255
rs->segment_file_size(cast_set<int>(seg_id)),

be/src/common/config.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1167,7 +1167,7 @@ DEFINE_mInt64(file_cache_background_lru_dump_tail_record_num, "5000000");
11671167
DEFINE_mInt64(file_cache_background_lru_log_replay_interval_ms, "1000");
11681168
DEFINE_mBool(enable_evaluate_shadow_queue_diff, "false");
11691169

1170-
DEFINE_mBool(enable_only_warm_up_idx, "false");
1170+
DEFINE_mBool(file_cache_enable_only_warm_up_idx, "false");
11711171

11721172
DEFINE_Int32(file_cache_downloader_thread_num_min, "32");
11731173
DEFINE_Int32(file_cache_downloader_thread_num_max, "32");

be/src/common/config.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1209,7 +1209,7 @@ DECLARE_mInt64(file_cache_background_lru_dump_tail_record_num);
12091209
DECLARE_mInt64(file_cache_background_lru_log_replay_interval_ms);
12101210
DECLARE_mBool(enable_evaluate_shadow_queue_diff);
12111211

1212-
DECLARE_mBool(enable_only_warm_up_idx);
1212+
DECLARE_mBool(file_cache_enable_only_warm_up_idx);
12131213

12141214
// inverted index searcher cache
12151215
// cache entry stay time after lookup

0 commit comments

Comments
 (0)