Update datafusion/core/tests/physical_optimizer/enforce_distribution.rs

xudong963 · alamb · web-flow · commit e6d833d03b46 · 2025-02-03T23:05:44.000+08:00
Co-authored-by: Andrew Lamb &lt;andrew@nerdnetworks.org&gt;
diff --git a/datafusion/core/tests/physical_optimizer/enforce_distribution.rs b/datafusion/core/tests/physical_optimizer/enforce_distribution.rs
@@ -3252,7 +3252,7 @@ async fn apply_enforce_distribution_multiple_times() -> Result<()> {
         .unwrap();
 
     let batch = results.next().await.unwrap()?;
-    // With the fix of https://github.com/apache/datafusion/pull/14207, the number of rows will be 10
+    // Without the fix of https://github.com/apache/datafusion/pull/14207, the number of rows will be 10
     assert_eq!(batch.num_rows(), 5);
     Ok(())
 }

Original file line number	Diff line number	Diff line change
`@@ -3252,7 +3252,7 @@ async fn apply_enforce_distribution_multiple_times() -> Result<()> {`
`3252`	`3252`	`.unwrap();`
`3253`	`3253`
`3254`	`3254`	`let batch = results.next().await.unwrap()?;`
`3255`		`- // With the fix of https://github.com/apache/datafusion/pull/14207, the number of rows will be 10`
	`3255`	`+ // Without the fix of https://github.com/apache/datafusion/pull/14207, the number of rows will be 10`
`3256`	`3256`	`assert_eq!(batch.num_rows(), 5);`
`3257`	`3257`	`Ok(())`
`3258`	`3258`	`}`