We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8552245 commit 2636480Copy full SHA for 2636480
1 file changed
datafusion/physical-plan/src/joins/hash_join/exec.rs
@@ -1383,10 +1383,8 @@ impl ExecutionPlan for HashJoinExec {
1383
let null_equality = self.null_equality;
1384
let background_join_metrics = join_metrics.clone();
1385
1386
- if build_accumulator.is_some() {
+ if let Some((build_accumulator, partition)) = build_accumulator {
1387
let (tx, rx) = oneshot::channel();
1388
- let (build_accumulator, partition) =
1389
- build_accumulator.expect("checked is_some above");
1390
let background_build_accumulator = Arc::clone(&build_accumulator);
1391
let task = SpawnedTask::spawn(async move {
1392
let result = collect_left_input_and_maybe_report(
0 commit comments