From 91d755d9b55262aa21e3b9d013cd10e319aef490 Mon Sep 17 00:00:00 2001 From: evenyag Date: Thu, 13 Feb 2025 22:49:02 +0800 Subject: [PATCH] feat: use spawn --- src/mito2/src/region_write_ctx.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mito2/src/region_write_ctx.rs b/src/mito2/src/region_write_ctx.rs index eafe994e0c..2cb2a1ec24 100644 --- a/src/mito2/src/region_write_ctx.rs +++ b/src/mito2/src/region_write_ctx.rs @@ -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)?;