chore: apply suggestions from CR

GreptimeTeam · Aug 27, 2024 · 5674ef0 · 5674ef0
1 parent 6843b86
commit 5674ef0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/log-store/src/kafka/index.rs b/src/log-store/src/kafka/index.rs
@@ -26,5 +26,5 @@ pub(crate) use iterator::{
 pub(crate) use iterator::{MultipleRegionWalIndexIterator, RegionWalRange, RegionWalVecIndex};
 
 pub fn default_index_file(location_id: u64) -> String {
-    format!("__datanode/{location_id}/index.json")
+    format!("__wal/{location_id}/index.json")
 }
diff --git a/src/mito2/src/wal.rs b/src/mito2/src/wal.rs
@@ -109,9 +109,9 @@ impl<S: LogStore> Wal<S> {
                 LogStoreRawEntryReader::new(self.store.clone()),
             )),
             Provider::Kafka(_) => {
-                let reader = if let Some(from_peer_id) = location_id {
+                let reader = if let Some(location_id) = location_id {
                     LogStoreRawEntryReader::new(self.store.clone())
-                        .with_wal_index(WalIndex::new(region_id, from_peer_id))
+                        .with_wal_index(WalIndex::new(region_id, location_id))
                 } else {
                     LogStoreRawEntryReader::new(self.store.clone())
                 };