diff --git a/native/core/src/execution/jni_api.rs b/native/core/src/execution/jni_api.rs index a29b83803c..927397977d 100644 --- a/native/core/src/execution/jni_api.rs +++ b/native/core/src/execution/jni_api.rs @@ -135,6 +135,8 @@ pub unsafe extern "system" fn Java_org_apache_comet_Native_createPlan( // Use multi-threaded tokio runtime to prevent blocking spawned tasks if any let runtime = tokio::runtime::Builder::new_multi_thread() + .worker_threads(4) + .max_blocking_threads(10) .enable_all() .build()?;