refactor: Switch to global IO runtime for pruning (#10941)

Signed-off-by: Xuanwo <[email protected]>

Author: Xuanwo

src/query/storages/fuse/src/pruning/fuse_pruner.rs

@@ -16,6 +16,7 @@ use std::collections::HashMap;
 use std::sync::Arc;
 
 use common_base::base::tokio::sync::Semaphore;
+use common_base::runtime::GlobalIORuntime;
 use common_base::runtime::Runtime;
 use common_catalog::plan::PushDownInfo;
 use common_catalog::table_context::TableContext;
@@ -118,7 +119,7 @@ impl FusePruner {
         )?;
 
         // Constraint the degree of parallelism
-        let max_threads = ctx.get_settings().get_max_threads()? as usize;
+        // let max_threads = ctx.get_settings().get_max_threads()? as usize;
         let max_concurrency = {
             let max_io_requests = ctx.get_settings().get_max_storage_io_requests()? as usize;
             // Prevent us from miss-configured max_storage_io_requests setting, e.g. 0
@@ -133,17 +134,18 @@ impl FusePruner {
         };
 
         // Pruning runtime.
-        let pruning_runtime = Arc::new(Runtime::with_worker_threads(
-            max_threads,
-            Some("pruning-worker".to_owned()),
-        )?);
+        // let pruning_runtime = Arc::new(Runtime::with_worker_threads(
+        //     max_threads,
+        //     Some("pruning-worker".to_owned()),
+        // )?);
         let pruning_semaphore = Arc::new(Semaphore::new(max_concurrency));
         let pruning_stats = Arc::new(FusePruningStatistics::default());
 
         let pruning_ctx = Arc::new(PruningContext {
             ctx: ctx.clone(),
             dal,
-            pruning_runtime,
+            // TODO: we should switch back to pruning_runtime after we figure out the root cause of hang.
+            pruning_runtime: GlobalIORuntime::instance(),
             pruning_semaphore,
             limit_pruner,
             range_pruner,