refactor(aggregator): try fix drop twice states
@@ -88,12 +88,13 @@ where
instant.elapsed()
);
+ self.states_dropped = true;
Ok(TwoLevelAggregator::<Self> {
inner: PartialAggregator::<true, TwoLevelHashMethod<Method>> {
area: self.area.take(),
params: self.params.clone(),
is_generated: self.is_generated,
- states_dropped: self.states_dropped,
+ states_dropped: false,
method: two_level_method,
hash_table: two_level_hashtable,
},
@@ -139,12 +140,13 @@ where
instant.elapsed()
);
+ self.states_dropped = true;
Ok(TwoLevelAggregator::<Self> {
inner: PartialAggregator::<false, TwoLevelHashMethod<Method>> {
area: self.area.take(),
params: self.params.clone(),
is_generated: self.is_generated,
- states_dropped: self.states_dropped,
+ states_dropped: false,
method: two_level_method,
hash_table: two_level_hashtable,
},
