rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-05 21:02:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: use spawn

Browse Source
This commit is contained in:
evenyag
2025-02-13 22:49:02 +08:00
parent 2566d254ad
commit 91d755d9b5
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/mito2/src/region_write_ctx.rs
View File

@@ -257,7 +257,7 @@ impl RegionWriteCtx {
let mut tasks = Vec::with_capacity(self.wal_entry.mutations.len());
for mutation in self.wal_entry.mutations.drain(..) {
let metadata = self.version.metadata.clone();
let task = common_runtime::spawn_blocking_global(move || {
let task = common_runtime::spawn_global(async move {
let encoder = BulkPartEncoder::new(metadata, true, DEFAULT_ROW_GROUP_SIZE);
let mutations = [mutation];
let part_opt = encoder.encode_mutations(&mutations)?;