Skip to content

Commit 7265cff

Browse files
committed
Release join_permit
1 parent eee9c59 commit 7265cff

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

  • datafusion/physical-plan/src/joins/grace_hash_join

datafusion/physical-plan/src/joins/grace_hash_join/stream.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1236,6 +1236,7 @@ impl GraceHashJoinStream {
12361236
);
12371237
}
12381238
}
1239+
*join_permit = None;
12391240
return Poll::Ready(Some(Err(e)));
12401241
}
12411242
None => {

0 commit comments

Comments
 (0)