We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 060a869 commit bb0644fCopy full SHA for bb0644f
1 file changed
datafusion/physical-plan/src/joins/grace_hash_join/stream.rs
@@ -1214,12 +1214,12 @@ impl GraceHashJoinStream {
1214
total
1215
};
1216
if bytes_to_free > 0 {
1217
- let mut res = self.reservation.lock();
+ let mut res = reservation.lock();
1218
if res.try_shrink(bytes_to_free).is_err() {
1219
let freed = res.free();
1220
debug!(
1221
- "Grace hash join stream completion freed {} after shrink failure (requested {})",
1222
- human_readable_size(freed),
+ "Grace hash join stream completion freed {} after shrink failure (requested {})",
+ human_readable_size(freed),
1223
human_readable_size(bytes_to_free)
1224
);
1225
}
0 commit comments