execution: initialize next in aggregation even if we aggregate the la…

…bels away
thanos-io · Jan 3, 2025 · d0576aa · d0576aa
1 parent 9dbff30
commit d0576aa
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/execution/aggregate/hashaggregate.go b/execution/aggregate/hashaggregate.go
@@ -220,6 +220,11 @@ func (a *aggregate) initializeTables(ctx context.Context) error {
 }
 
 func (a *aggregate) initializeVectorizedTables(ctx context.Context) ([]aggregateTable, []labels.Labels, error) {
+	// perform initialization of the underlying operator even if we are aggregating the labels away
+	_, err := a.next.Series(ctx)
+	if err != nil {
+		return nil, nil, err
+	}
 	tables, err := newVectorizedTables(a.stepsBatch, a.aggregation)
 	if errors.Is(err, parse.ErrNotSupportedExpr) {
 		return a.initializeScalarTables(ctx)