File tree Expand file tree Collapse file tree
datafusion/physical-plan/src/joins Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1046,10 +1046,15 @@ mod tests {
10461046
10471047 let err = join_collect ( left, right, task_ctx) . await . unwrap_err ( ) ;
10481048
1049+ let err_str = err. to_string ( ) ;
10491050 assert_contains ! (
1050- err . to_string ( ) ,
1051- "Resources exhausted: Additional allocation failed for CrossJoinExec[left] with top memory consumers (across reservations) as: \n CrossJoinExec[left] "
1051+ & err_str ,
1052+ "Resources exhausted: Additional allocation failed for CrossJoinExec[left]"
10521053 ) ;
1054+ // Both sides buffer upfront, so each appears as a memory consumer;
1055+ // their order in the top-consumers list is not deterministic.
1056+ assert_contains ! ( & err_str, "CrossJoinExec[left]" ) ;
1057+ assert_contains ! ( & err_str, "CrossJoinExec[right]" ) ;
10531058
10541059 Ok ( ( ) )
10551060 }
You can’t perform that action at this time.
0 commit comments