Update parquet common to latest main to pull sort series fix (#6988)

* update parquet common to latest main to pull sort series fix

Signed-off-by: Ben Ye <[email protected]>

* fix build

Signed-off-by: Ben Ye <[email protected]>

* update to latest

Signed-off-by: Ben Ye <[email protected]>

---------

Signed-off-by: Ben Ye <[email protected]>

Author: yeya24

go.mod

@@ -84,7 +84,7 @@ require (
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822
 	github.com/oklog/ulid/v2 v2.1.1
 	github.com/parquet-go/parquet-go v0.25.1
-	github.com/prometheus-community/parquet-common v0.0.0-20250807102632-2aeeceacebf0
+	github.com/prometheus-community/parquet-common v0.0.0-20250827225610-65f0b68d35e6
 	github.com/prometheus/procfs v0.16.1
 	github.com/sercand/kuberesolver/v5 v5.1.1
 	github.com/tjhop/slog-gokit v0.1.4

go.sum

@@ -1611,8 +1611,8 @@ github.com/posener/complete v1.1.1/go.mod h1:em0nMJCgc9GFtwrmVmEMR/ZL6WyhyjMBndr
 github.com/posener/complete v1.2.3/go.mod h1:WZIdtGGp+qx0sLrYKtIRAruyNpv6hFCicSgv7Sy7s/s=
 github.com/prashantv/gostub v1.1.0 h1:BTyx3RfQjRHnUWaGF9oQos79AlQ5k8WNktv7VGvVH4g=
 github.com/prashantv/gostub v1.1.0/go.mod h1:A5zLQHz7ieHGG7is6LLXLz7I8+3LZzsrV0P1IAHhP5U=
-github.com/prometheus-community/parquet-common v0.0.0-20250807102632-2aeeceacebf0 h1:5mm5mMmEhUdvqf4NsVvEGWry0IeXkeZEfODbZ70c1Ok=
-github.com/prometheus-community/parquet-common v0.0.0-20250807102632-2aeeceacebf0/go.mod h1:MbAv/yCv9GORLj0XvXgRF913R9Jc04+BvVq4VJpPCi0=
+github.com/prometheus-community/parquet-common v0.0.0-20250827225610-65f0b68d35e6 h1:jWcDrCpAU047f2NTGtm3vRPqJ8skDOkdKCC5sSfSN4Q=
+github.com/prometheus-community/parquet-common v0.0.0-20250827225610-65f0b68d35e6/go.mod h1:MbAv/yCv9GORLj0XvXgRF913R9Jc04+BvVq4VJpPCi0=
 github.com/prometheus-community/prom-label-proxy v0.11.1 h1:jX+m+BQCNM0z3/P6V6jVxbiDKgugvk91SaICD6bVhT4=
 github.com/prometheus-community/prom-label-proxy v0.11.1/go.mod h1:uTeQW+wZ/VPV1LL3IPfvUE++wR2nPLex+Y4RE38Cpis=
 github.com/prometheus/alertmanager v0.28.1 h1:BK5pCoAtaKg01BYRUJhEDV1tqJMEtYBGzPw8QdvnnvA=

pkg/querier/parquet_queryable.go

@@ -159,38 +159,34 @@ func NewParquetQueryable(
 			return int64(limits.ParquetMaxFetchedDataBytes(userID))
 		}),
 		queryable.WithMaterializedLabelsFilterCallback(materializedLabelsFilterCallback),
-		queryable.WithMaterializedSeriesCallback(func(ctx context.Context, cs []storage.ChunkSeries) error {
+		queryable.WithMaterializedSeriesCallback(func(ctx context.Context, series storage.ChunkSeries) error {
 			queryLimiter := limiter.QueryLimiterFromContextWithFallback(ctx)
-			lbls := make([][]cortexpb.LabelAdapter, 0, len(cs))
-			for _, series := range cs {
-				chkCount := 0
-				chunkSize := 0
-				lblSize := 0
-				lblAdapter := cortexpb.FromLabelsToLabelAdapters(series.Labels())
-				lbls = append(lbls, lblAdapter)
-				for _, lbl := range lblAdapter {
-					lblSize += lbl.Size()
-				}
-				iter := series.Iterator(nil)
-				for iter.Next() {
-					chk := iter.At()
-					chunkSize += len(chk.Chunk.Bytes())
-					chkCount++
-				}
-				if chkCount > 0 {
-					if err := queryLimiter.AddChunks(chkCount); err != nil {
-						return validation.LimitError(err.Error())
-					}
-					if err := queryLimiter.AddChunkBytes(chunkSize); err != nil {
-						return validation.LimitError(err.Error())
-					}
+			chkCount := 0
+			chunkSize := 0
+			lblSize := 0
+			lblAdapter := cortexpb.FromLabelsToLabelAdapters(series.Labels())
+			for _, lbl := range lblAdapter {
+				lblSize += lbl.Size()
+			}
+			iter := series.Iterator(nil)
+			for iter.Next() {
+				chk := iter.At()
+				chunkSize += len(chk.Chunk.Bytes())
+				chkCount++
+			}
+			if chkCount > 0 {
+				if err := queryLimiter.AddChunks(chkCount); err != nil {
+					return validation.LimitError(err.Error())
 				}
-
-				if err := queryLimiter.AddDataBytes(chunkSize + lblSize); err != nil {
+				if err := queryLimiter.AddChunkBytes(chunkSize); err != nil {
 					return validation.LimitError(err.Error())
 				}
 			}
-			if err := queryLimiter.AddSeries(lbls...); err != nil {
+
+			if err := queryLimiter.AddDataBytes(chunkSize + lblSize); err != nil {
+				return validation.LimitError(err.Error())
+			}
+			if err := queryLimiter.AddSeries(lblAdapter); err != nil {
 				return validation.LimitError(err.Error())
 			}
 			return nil

pkg/querier/parquet_queryable_test.go

@@ -478,7 +478,7 @@ func TestParquetQueryable_Limits(t *testing.T) {
 				return validation.NewOverrides(limits, nil)
 			}(),
 			queryLimiter: limiter.NewQueryLimiter(0, 1, 0, 0),
-			expectedErr:  fmt.Errorf("materializer failed to materialize chunks: would fetch too many chunk bytes: resource exhausted (used 1)"),
+			expectedErr:  fmt.Errorf("materializer failed to create chunks iterator: failed to create column value iterator: would fetch too many chunk bytes: resource exhausted (used 1)"),
 		},
 		"max chunk bytes per query limit hit": {
 			limits: func() *validation.Overrides {