From 5e35087b676cb2be50adf2b319f014317d04eaa1 Mon Sep 17 00:00:00 2001 From: Ruihang Xia Date: Fri, 15 Sep 2023 22:23:36 -0500 Subject: [PATCH] fix: generate region path with given prefix (#2409) Signed-off-by: Ruihang Xia --- src/datanode/src/datanode.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/datanode/src/datanode.rs b/src/datanode/src/datanode.rs index 4c79c0ebde..9e3d25fa1b 100644 --- a/src/datanode/src/datanode.rs +++ b/src/datanode/src/datanode.rs @@ -38,7 +38,7 @@ use query::QueryEngineFactory; use servers::Mode; use snafu::{OptionExt, ResultExt}; use store_api::logstore::LogStore; -use store_api::path_utils::WAL_DIR; +use store_api::path_utils::{region_dir, WAL_DIR}; use store_api::region_engine::RegionEngineRef; use store_api::region_request::{RegionOpenRequest, RegionRequest}; use store_api::storage::RegionId; @@ -246,7 +246,8 @@ impl DatanodeBuilder { info!("going to open {} regions", regions.len()); - for (region_id, engine, region_dir) in regions { + for (region_id, engine, store_path) in regions { + let region_dir = region_dir(&store_path, region_id); region_server .handle_request( region_id,