nit: updated code comments

Author: naman-modi

datafusion/core/tests/fuzz_cases/aggregation_fuzzer/context_generator.rs

@@ -221,18 +221,16 @@ impl SessionContextGenerator {
         // Decide spilling first; it constrains batch_size and partitions below.
         let spilling = agg_peak > 0 && rng.random_bool(0.5);
 
-        // Cap batch_size when spilling. The spill reserves ~2x the emitted batch
-        // to sort it, so a large batch needs a pool bigger than the aggregate's
-        // peak and never spills. Large batches stay covered by the unbounded rounds.
+        // Cap batch_size when spilling. The spill reserves ~2x the emitted batch to sort it, so a large batch
+        // needs a pool bigger than the aggregate's peak and never spills. Large batches stay covered by the unbounded rounds.
         let batch_size = if spilling {
             rng.random_range(1..=cmp::min(self.max_batch_size, SPILL_BATCH_SIZE_CAP))
         } else {
             rng.random_range(1..=self.max_batch_size)
         };
 
-        // Single partition when spilling. `FairSpillPool` splits across the
-        // per-partition aggregate consumers, so with many partitions each share
-        // is too small and hits `ResourcesExhausted` before it can spill. Multi
+        // Single partition when spilling. `FairSpillPool` splits across the  per-partition aggregate consumers,
+        // so with many partitions each share is too small and hits `ResourcesExhausted` before it can spill. Multi
         // partition stays covered by the unbounded rounds.
         let target_partitions = if spilling {
             1

datafusion/core/tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs

@@ -275,9 +275,8 @@ impl AggregationFuzzTestTask {
     async fn run(&self) -> Result<()> {
         let task_result = match run_sql(&self.sql, &self.ctx_with_params.ctx).await {
             Ok(result) => result,
-            // A bounded pool too tight to even spill fails with
-            // `ResourcesExhausted`. Not a correctness bug, so skip and log it
-            // (no silent drop) instead of failing the run.
+            // A bounded pool too tight to even spill fails with `ResourcesExhausted`. Not a correctness bug, so skip
+            // and log it (no silent drop) instead of failing the run.
             Err(e)
                 if self.ctx_with_params.params.memory_limit().is_some()
                     && matches!(