Skip to content

Commit 92dc253

Browse files
committed
chore: aft rebase fix
Signed-off-by: discord9 <[email protected]>
1 parent 4150db7 commit 92dc253

File tree

6 files changed

+7
-10
lines changed

6 files changed

+7
-10
lines changed

src/datanode/src/heartbeat/handler/gc_worker.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,7 @@ use mito2::gc::LocalGcWorker;
1818
use snafu::{OptionExt, ResultExt};
1919
use store_api::storage::{FileRefsManifest, RegionId};
2020

21-
use crate::error::{
22-
GcMitoEngineSnafu, InvalidGcArgsSnafu, RegionNotFoundSnafu, Result, UnexpectedSnafu,
23-
};
21+
use crate::error::{GcMitoEngineSnafu, InvalidGcArgsSnafu, Result, UnexpectedSnafu};
2422
use crate::heartbeat::handler::HandlerContext;
2523

2624
impl HandlerContext {

src/meta-srv/src/gc_scheduler.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ use std::sync::Arc;
1717
use std::time::{Duration, Instant};
1818

1919
use api::v1::meta::MailboxMessage;
20-
use common_meta::datanode::{GcStat, RegionManifestInfo, RegionStat};
20+
use common_meta::datanode::{RegionManifestInfo, RegionStat};
2121
use common_meta::instruction::{
2222
GcRegions, GetFileRefs, GetFileRefsReply, Instruction, InstructionReply,
2323
};

src/mito2/src/engine.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ use common_base::Plugins;
8282
use common_error::ext::BoxedError;
8383
use common_meta::key::SchemaMetadataManagerRef;
8484
use common_recordbatch::SendableRecordBatchStream;
85-
use common_telemetry::{info, tracing, warn, debug};
85+
use common_telemetry::{info, tracing, warn};
8686
use common_wal::options::{WAL_OPTIONS_KEY, WalOptions};
8787
use futures::future::{join_all, try_join_all};
8888
use futures::stream::{self, Stream, StreamExt};
@@ -102,7 +102,7 @@ use store_api::region_engine::{
102102
};
103103
use store_api::region_request::{AffectedRows, RegionOpenRequest, RegionRequest};
104104
use store_api::sst_entry::{ManifestSstEntry, PuffinIndexMetaEntry, StorageSstEntry};
105-
use store_api::storage::{FileRefsManifest, FileId, RegionId, ScanRequest, SequenceNumber, TableId};
105+
use store_api::storage::{FileId, FileRefsManifest, RegionId, ScanRequest, SequenceNumber};
106106
use tokio::sync::{Semaphore, oneshot};
107107

108108
use crate::access_layer::RegionFilePathFactory;

src/mito2/src/region/opener.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ use crate::region_write_ctx::RegionWriteCtx;
6262
use crate::request::OptionOutputTx;
6363
use crate::schedule::scheduler::SchedulerRef;
6464
use crate::sst::FormatType;
65-
use crate::sst::file_purger::{create_file_purger, create_local_file_purger};
65+
use crate::sst::file_purger::create_file_purger;
6666
use crate::sst::file_ref::FileReferenceManagerRef;
6767
use crate::sst::index::intermediate::IntermediateManager;
6868
use crate::sst::index::puffin_manager::PuffinManagerFactory;

src/mito2/src/test_util.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,7 @@ impl TestEnv {
609609
0,
610610
manifest_opts,
611611
FormatType::PrimaryKey,
612-
Default::default(),
612+
&Default::default(),
613613
)
614614
.await
615615
.map(Some)

src/store-api/src/storage/file.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,8 +117,7 @@ impl GcReport {
117117
.or_default()
118118
.extend(files.into_iter());
119119
}
120-
self.need_retry_regions
121-
.extend(other.need_retry_regions.into_iter());
120+
self.need_retry_regions.extend(other.need_retry_regions);
122121
}
123122
}
124123

0 commit comments

Comments
 (0)