You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2026/04/15 04:17:36 UTC
(doris) branch branch-4.0 updated: branch-4.0: [fix](cloud) Fix warm up cache not supporting packed file (#60375) (#61887)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new d6ae1ea92bc branch-4.0: [fix](cloud) Fix warm up cache not supporting packed file (#60375) (#61887)
d6ae1ea92bc is described below
commit d6ae1ea92bc7f3a8ae8588003a76dca94fae550f
Author: Xin Liao <li...@selectdb.com>
AuthorDate: Wed Apr 15 12:17:27 2026 +0800
branch-4.0: [fix](cloud) Fix warm up cache not supporting packed file (#60375) (#61887)
Pick apache/doris#60375
---
be/src/cloud/cloud_tablet.cpp | 11 +++++++++--
be/src/io/cache/block_file_cache_downloader.cpp | 12 +++++++++++-
.../balance/test_alter_compute_group_properties.groovy | 8 ++++++++
.../suites/cloud_p0/balance/test_balance_metrics.groovy | 8 +++++++-
.../balance/test_balance_use_compute_group_properties.groovy | 8 +++++++-
.../suites/cloud_p0/balance/test_balance_warm_up.groovy | 8 +++++++-
.../balance/test_balance_warm_up_sync_global_config.groovy | 8 +++++++-
.../balance/test_balance_warm_up_task_abnormal.groovy | 8 +++++++-
.../balance/test_balance_warm_up_use_peer_cache.groovy | 8 +++++++-
...est_balance_warm_up_with_compaction_use_peer_cache.groovy | 8 +++++++-
.../cloud_p0/balance/test_expanding_node_balance.groovy | 7 +++++++
.../cloud_p0/balance/test_peer_read_async_warmup.groovy | 6 ++++++
.../suites/cloud_p0/balance/test_warmup_rebalance.groovy | 8 ++++++++
regression-test/suites/cloud_p0/cache/test_load_cache.groovy | 5 +++++
.../suites/cloud_p0/cache/test_topn_broadcast.groovy | 6 +++++-
.../cloud_p0/tablets/test_clean_stale_rs_file_cache.groovy | 8 +++++++-
.../tablets/test_clean_stale_rs_index_file_cache.groovy | 8 +++++++-
.../tablets/test_clean_tablet_when_drop_force_table.groovy | 8 +++++++-
.../cloud_p0/tablets/test_clean_tablet_when_rebalance.groovy | 8 +++++++-
19 files changed, 136 insertions(+), 15 deletions(-)
diff --git a/be/src/cloud/cloud_tablet.cpp b/be/src/cloud/cloud_tablet.cpp
index 1624dfc9f54..19bc5b92791 100644
--- a/be/src/cloud/cloud_tablet.cpp
+++ b/be/src/cloud/cloud_tablet.cpp
@@ -467,11 +467,18 @@ void CloudTablet::add_rowsets(std::vector<RowsetSharedPtr> to_add, bool version_
}
// clang-format off
auto self = std::dynamic_pointer_cast<CloudTablet>(shared_from_this());
+ auto file_system = rowset_meta->fs();
+ if (!file_system) {
+ LOG(WARNING) << "failed to get file system for tablet_id="
+ << _tablet_meta->tablet_id() << ", rowset_id="
+ << rowset_meta->rowset_id();
+ continue;
+ }
if (!config::file_cache_enable_only_warm_up_idx) {
_engine.file_cache_block_downloader().submit_download_task(io::DownloadFileMeta {
.path = storage_resource.value()->remote_segment_path(*rowset_meta, seg_id),
.file_size = rs->rowset_meta()->segment_file_size(seg_id),
- .file_system = storage_resource.value()->fs,
+ .file_system = file_system,
.ctx =
{
.expiration_time = expiration_time,
@@ -503,7 +510,7 @@ void CloudTablet::add_rowsets(std::vector<RowsetSharedPtr> to_add, bool version_
io::DownloadFileMeta meta {
.path = idx_path,
.file_size = idx_size,
- .file_system = storage_resource.value()->fs,
+ .file_system = file_system,
.ctx =
{
.expiration_time = expiration_time,
diff --git a/be/src/io/cache/block_file_cache_downloader.cpp b/be/src/io/cache/block_file_cache_downloader.cpp
index 567eab3ad98..a74ddcad627 100644
--- a/be/src/io/cache/block_file_cache_downloader.cpp
+++ b/be/src/io/cache/block_file_cache_downloader.cpp
@@ -218,6 +218,16 @@ void FileCacheBlockDownloader::download_file_cache_block(
LOG(WARNING) << storage_resource.error();
return;
}
+ // Use RowsetMeta::fs() instead of storage_resource->fs to support packed file.
+ // RowsetMeta::fs() wraps the underlying FileSystem with PackedFileSystem when
+ // packed_slice_locations is not empty, which correctly maps segment file paths
+ // to their actual locations within packed files.
+ auto file_system = find_it->second->fs();
+ if (!file_system) {
+ LOG(WARNING) << "download_file_cache_block: failed to get file system for tablet_id="
+ << meta.tablet_id() << ", rowset_id=" << meta.rowset_id();
+ return;
+ }
auto download_done = [&, tablet_id = meta.tablet_id()](Status st) {
std::lock_guard lock(_inflight_mtx);
@@ -278,7 +288,7 @@ void FileCacheBlockDownloader::download_file_cache_block(
: -1, // To avoid trigger get file size IO
.offset = meta.offset(),
.download_size = meta.size(),
- .file_system = storage_resource.value()->fs,
+ .file_system = file_system,
.ctx =
{
.is_index_data = meta.cache_type() == ::doris::FileCacheType::INDEX,
diff --git a/regression-test/suites/cloud_p0/balance/test_alter_compute_group_properties.groovy b/regression-test/suites/cloud_p0/balance/test_alter_compute_group_properties.groovy
index e0db0c258e7..af049c001f0 100644
--- a/regression-test/suites/cloud_p0/balance/test_alter_compute_group_properties.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_alter_compute_group_properties.groovy
@@ -22,12 +22,20 @@ suite('test_alter_compute_group_properties', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
'cloud_tablet_rebalancer_interval_second=1',
'sys_log_verbose_modules=org',
]
+ options.beConfigs += [
+ "enable_packed_file=${enablePackedFile}",
+ ]
options.setFeNum(1)
options.setBeNum(1)
options.cloudMode = true
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_metrics.groovy b/regression-test/suites/cloud_p0/balance/test_balance_metrics.groovy
index eb81ad69524..af6389a297e 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_metrics.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_metrics.groovy
@@ -22,6 +22,11 @@ suite('test_balance_metrics', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -35,7 +40,8 @@ suite('test_balance_metrics', 'docker') {
'report_tablet_interval_seconds=1',
'schedule_sync_tablets_interval_s=18000',
'disable_auto_compaction=true',
- 'sys_log_verbose_modules=*'
+ 'sys_log_verbose_modules=*',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_use_compute_group_properties.groovy b/regression-test/suites/cloud_p0/balance/test_balance_use_compute_group_properties.groovy
index f96119ec29b..ef3cc7d81d5 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_use_compute_group_properties.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_use_compute_group_properties.groovy
@@ -22,6 +22,11 @@ suite('test_balance_use_compute_group_properties', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -36,7 +41,8 @@ suite('test_balance_use_compute_group_properties', 'docker') {
'report_tablet_interval_seconds=1',
'schedule_sync_tablets_interval_s=18000',
'disable_auto_compaction=true',
- 'sys_log_verbose_modules=*'
+ 'sys_log_verbose_modules=*',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_warm_up.groovy b/regression-test/suites/cloud_p0/balance/test_balance_warm_up.groovy
index db28efafad8..7dd33b603f6 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_warm_up.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_warm_up.groovy
@@ -22,6 +22,11 @@ suite('test_balance_warm_up', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -37,7 +42,8 @@ suite('test_balance_warm_up', 'docker') {
'disable_auto_compaction=true',
'sys_log_verbose_modules=*',
'cache_read_from_peer_expired_seconds=100',
- 'enable_cache_read_from_peer=true'
+ 'enable_cache_read_from_peer=true',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_sync_global_config.groovy b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_sync_global_config.groovy
index 19c252fba85..9469ac3855d 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_sync_global_config.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_sync_global_config.groovy
@@ -22,6 +22,11 @@ suite('test_balance_warm_up_sync_cache', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -36,7 +41,8 @@ suite('test_balance_warm_up_sync_cache', 'docker') {
'report_tablet_interval_seconds=1',
'schedule_sync_tablets_interval_s=18000',
'disable_auto_compaction=true',
- 'sys_log_verbose_modules=*'
+ 'sys_log_verbose_modules=*',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_task_abnormal.groovy b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_task_abnormal.groovy
index 0938126d61c..5cb20027887 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_task_abnormal.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_task_abnormal.groovy
@@ -22,6 +22,11 @@ suite('test_balance_warm_up_task_abnormal', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -36,7 +41,8 @@ suite('test_balance_warm_up_task_abnormal', 'docker') {
'report_tablet_interval_seconds=1',
'schedule_sync_tablets_interval_s=18000',
'disable_auto_compaction=true',
- 'sys_log_verbose_modules=*'
+ 'sys_log_verbose_modules=*',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_use_peer_cache.groovy b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_use_peer_cache.groovy
index f9202e702ed..93a31b559c2 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_use_peer_cache.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_use_peer_cache.groovy
@@ -22,6 +22,11 @@ suite('test_balance_warm_up_use_peer_cache', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -40,7 +45,8 @@ suite('test_balance_warm_up_use_peer_cache', 'docker') {
'disable_auto_compaction=true',
'sys_log_verbose_modules=*',
'cache_read_from_peer_expired_seconds=100',
- 'enable_cache_read_from_peer=true'
+ 'enable_cache_read_from_peer=true',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_with_compaction_use_peer_cache.groovy b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_with_compaction_use_peer_cache.groovy
index be120221019..3730a8f603a 100644
--- a/regression-test/suites/cloud_p0/balance/test_balance_warm_up_with_compaction_use_peer_cache.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_balance_warm_up_with_compaction_use_peer_cache.groovy
@@ -22,6 +22,11 @@ suite('test_balance_warm_up_with_compaction_use_peer_cache', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -41,7 +46,8 @@ suite('test_balance_warm_up_with_compaction_use_peer_cache', 'docker') {
'sys_log_verbose_modules=*',
'cumulative_compaction_min_deltas=5',
'cache_read_from_peer_expired_seconds=100',
- 'enable_cache_read_from_peer=true'
+ 'enable_cache_read_from_peer=true',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_expanding_node_balance.groovy b/regression-test/suites/cloud_p0/balance/test_expanding_node_balance.groovy
index 4a9b77b5491..58472d46a75 100644
--- a/regression-test/suites/cloud_p0/balance/test_expanding_node_balance.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_expanding_node_balance.groovy
@@ -23,6 +23,10 @@ suite('test_expanding_node_balance', 'docker') {
return;
}
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def clusterOptions = [
new ClusterOptions(),
new ClusterOptions(),
@@ -40,6 +44,9 @@ suite('test_expanding_node_balance', 'docker') {
// disable Auto Analysis Job Executor
'auto_check_statistics_in_minutes=60',
]
+ options.beConfigs += [
+ "enable_packed_file=${enablePackedFile}",
+ ]
options.cloudMode = true
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_peer_read_async_warmup.groovy b/regression-test/suites/cloud_p0/balance/test_peer_read_async_warmup.groovy
index ba9a61409bb..cd8e510e933 100644
--- a/regression-test/suites/cloud_p0/balance/test_peer_read_async_warmup.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_peer_read_async_warmup.groovy
@@ -22,6 +22,11 @@ suite('test_peer_read_async_warmup', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -39,6 +44,7 @@ suite('test_peer_read_async_warmup', 'docker') {
'disable_auto_compaction=true',
'sys_log_verbose_modules=*',
'enable_cache_read_from_peer=true',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/balance/test_warmup_rebalance.groovy b/regression-test/suites/cloud_p0/balance/test_warmup_rebalance.groovy
index c0dc2f9747c..e2ca3aeba63 100644
--- a/regression-test/suites/cloud_p0/balance/test_warmup_rebalance.groovy
+++ b/regression-test/suites/cloud_p0/balance/test_warmup_rebalance.groovy
@@ -22,6 +22,11 @@ suite('test_warmup_rebalance_in_cloud', 'multi_cluster, docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -31,6 +36,9 @@ suite('test_warmup_rebalance_in_cloud', 'multi_cluster, docker') {
'sys_log_verbose_modules=org',
'cloud_pre_heating_time_limit_sec=600'
]
+ options.beConfigs += [
+ "enable_packed_file=${enablePackedFile}",
+ ]
options.setFeNum(2)
options.setBeNum(3)
options.cloudMode = true
diff --git a/regression-test/suites/cloud_p0/cache/test_load_cache.groovy b/regression-test/suites/cloud_p0/cache/test_load_cache.groovy
index 25f9929aaf7..7fe5c517382 100644
--- a/regression-test/suites/cloud_p0/cache/test_load_cache.groovy
+++ b/regression-test/suites/cloud_p0/cache/test_load_cache.groovy
@@ -33,6 +33,10 @@ changes to statistics are possible, only a reasonable range is required.
*/
suite('test_load_cache', 'docker') {
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -41,6 +45,7 @@ suite('test_load_cache', 'docker') {
'file_cache_enter_disk_resource_limit_mode_percent=99',
'enable_evict_file_cache_in_advance=false',
'file_cache_background_monitor_interval_ms=1000',
+ "enable_packed_file=${enablePackedFile}",
]
options.cloudMode = true
options.beNum = 1
diff --git a/regression-test/suites/cloud_p0/cache/test_topn_broadcast.groovy b/regression-test/suites/cloud_p0/cache/test_topn_broadcast.groovy
index 2fb8d834f11..340191423e3 100644
--- a/regression-test/suites/cloud_p0/cache/test_topn_broadcast.groovy
+++ b/regression-test/suites/cloud_p0/cache/test_topn_broadcast.groovy
@@ -21,6 +21,9 @@ import org.apache.doris.regression.suite.ClusterOptions
suite("test_topn_broadcast", "docker") {
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
def options = new ClusterOptions()
@@ -32,7 +35,8 @@ suite("test_topn_broadcast", "docker") {
options.beConfigs += ['enable_file_cache=true', 'enable_java_support=false', 'file_cache_enter_disk_resource_limit_mode_percent=99',
'file_cache_background_lru_dump_interval_ms=2000', 'file_cache_background_lru_log_replay_interval_ms=500',
'disable_auto_compation=true', 'file_cache_enter_need_evict_cache_in_advance_percent=99',
- 'file_cache_background_lru_dump_update_cnt_threshold=0'
+ 'file_cache_background_lru_dump_update_cnt_threshold=0',
+ "enable_packed_file=${enablePackedFile}",
]
docker(options) {
diff --git a/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_file_cache.groovy b/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_file_cache.groovy
index 807e51ae95f..861394d0a27 100644
--- a/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_file_cache.groovy
+++ b/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_file_cache.groovy
@@ -22,6 +22,11 @@ suite('test_clean_stale_rs_file_cache', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -34,7 +39,8 @@ suite('test_clean_stale_rs_file_cache', 'docker') {
'cumulative_compaction_min_deltas=5',
'tablet_rowset_stale_sweep_by_size=false',
'tablet_rowset_stale_sweep_time_sec=60',
- 'vacuum_stale_rowsets_interval_s=10'
+ 'vacuum_stale_rowsets_interval_s=10',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_index_file_cache.groovy b/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_index_file_cache.groovy
index e99a5f96b36..eb969fe049a 100644
--- a/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_index_file_cache.groovy
+++ b/regression-test/suites/cloud_p0/tablets/test_clean_stale_rs_index_file_cache.groovy
@@ -22,6 +22,11 @@ suite('test_clean_stale_rs_index_file_cache', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -34,7 +39,8 @@ suite('test_clean_stale_rs_index_file_cache', 'docker') {
'cumulative_compaction_min_deltas=5',
'tablet_rowset_stale_sweep_by_size=false',
'tablet_rowset_stale_sweep_time_sec=60',
- 'vacuum_stale_rowsets_interval_s=10'
+ 'vacuum_stale_rowsets_interval_s=10',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(1)
options.setBeNum(1)
diff --git a/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_drop_force_table.groovy b/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_drop_force_table.groovy
index 6a48706718c..0f2c3b86932 100644
--- a/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_drop_force_table.groovy
+++ b/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_drop_force_table.groovy
@@ -22,6 +22,11 @@ suite('test_clean_tablet_when_drop_force_table', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
options.feConfigs += [
'cloud_cluster_check_interval_second=1',
@@ -34,7 +39,8 @@ suite('test_clean_tablet_when_drop_force_table', 'docker') {
'report_tablet_interval_seconds=1',
'write_buffer_size=10240',
'write_buffer_size_for_agg=10240',
- 'sys_log_verbose_modules=task_worker_pool'
+ 'sys_log_verbose_modules=task_worker_pool',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(3)
options.setBeNum(3)
diff --git a/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_rebalance.groovy b/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_rebalance.groovy
index 75c2c410a23..cd8c3704005 100644
--- a/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_rebalance.groovy
+++ b/regression-test/suites/cloud_p0/tablets/test_clean_tablet_when_rebalance.groovy
@@ -22,6 +22,11 @@ suite('test_clean_tablet_when_rebalance', 'docker') {
if (!isCloudMode()) {
return;
}
+
+ // Randomly enable or disable packed_file to test both scenarios
+ def enablePackedFile = new Random().nextBoolean()
+ logger.info("Running test with enable_packed_file=${enablePackedFile}")
+
def options = new ClusterOptions()
def rehashTime = 100
options.feConfigs += [
@@ -34,7 +39,8 @@ suite('test_clean_tablet_when_rebalance', 'docker') {
options.beConfigs += [
'report_tablet_interval_seconds=1',
'write_buffer_size=10240',
- 'write_buffer_size_for_agg=10240'
+ 'write_buffer_size_for_agg=10240',
+ "enable_packed_file=${enablePackedFile}",
]
options.setFeNum(3)
options.setBeNum(3)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org