modify the spilling judgement.

Author: Rachelint

datafusion/physical-plan/src/aggregates/row_hash.rs

@@ -41,7 +41,7 @@ use arrow::datatypes::SchemaRef;
 use datafusion_common::{internal_err, DataFusionError, Result};
 use datafusion_execution::disk_manager::RefCountedTempFile;
 use datafusion_execution::memory_pool::proxy::VecAllocExt;
-use datafusion_execution::memory_pool::{MemoryConsumer, MemoryReservation};
+use datafusion_execution::memory_pool::{MemoryConsumer, MemoryLimit, MemoryReservation};
 use datafusion_execution::TaskContext;
 use datafusion_expr::{EmitTo, GroupsAccumulator};
 use datafusion_physical_expr::expressions::Column;
@@ -683,7 +683,7 @@ fn maybe_enable_blocked_groups(
         .enable_aggregation_blocked_groups
         || !matches!(group_ordering, GroupOrdering::None)
         || accumulators.is_empty()
-        || context.runtime_env().disk_manager.tmp_files_enabled()
+        || matches!(context.memory_pool().memory_limit(), MemoryLimit::Infinite)
     {
         return Ok(false);
     }