Limit concurrency to 1

Vedin · Vedin · commit 63959078a140 · 2025-11-29T14:06:05.000+02:00
diff --git a/datafusion/physical-plan/src/joins/grace_hash_join/stream.rs b/datafusion/physical-plan/src/joins/grace_hash_join/stream.rs
@@ -71,7 +71,7 @@ fn prefetch_cap_bytes(_current_limit: usize) -> usize {
 
 fn global_join_semaphore() -> &'static Arc<Semaphore> {
     static SEM: OnceLock<Arc<Semaphore>> = OnceLock::new();
-    SEM.get_or_init(|| Arc::new(Semaphore::new(2)))
+    SEM.get_or_init(|| Arc::new(Semaphore::new(1)))
 }
 
 enum GraceJoinState {

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ fn prefetch_cap_bytes(_current_limit: usize) -> usize {`
`71`	`71`
`72`	`72`	`fn global_join_semaphore() -> &'static Arc<Semaphore> {`
`73`	`73`	`static SEM: OnceLock<Arc<Semaphore>> = OnceLock::new();`
`74`		`- SEM.get_or_init(\|\| Arc::new(Semaphore::new(2)))`
	`74`	`+ SEM.get_or_init(\|\| Arc::new(Semaphore::new(1)))`
`75`	`75`	`}`
`76`	`76`
`77`	`77`	`enum GraceJoinState {`