Skip to content

Commit

Permalink
Revert "Also check hash value"
Browse files Browse the repository at this point in the history
This reverts commit 50bfc7b.
  • Loading branch information
alamb committed Aug 5, 2021
1 parent 50bfc7b commit de95fef
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions datafusion/src/physical_plan/hash_aggregate.rs
Original file line number Diff line number Diff line change
Expand Up @@ -365,13 +365,10 @@ fn group_aggregate_batch(
for (row, hash) in batch_hashes.into_iter().enumerate() {
let Accumulators { map, group_states } = &mut accumulators;

let entry = map.get_mut(hash, |(existing_hash, group_idx)| {
let entry = map.get_mut(hash, |(_hash, group_idx)| {
// verify that a group that we are inserting with hash is
// actually the same key value as the group in
// existing_idx (aka group_values @ row)
if hash != *existing_hash {
return false;
}
let group_state = &group_states[*group_idx];
group_values
.iter()
Expand Down

0 comments on commit de95fef

Please sign in to comment.