Skip to content
This repository was archived by the owner on Jul 19, 2023. It is now read-only.

Commit 0884479

Browse files
committed
Pulll tempo sync
1 parent 0d755c9 commit 0884479

File tree

2 files changed

+633
-4
lines changed

2 files changed

+633
-4
lines changed

pkg/phlaredb/block_querier.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1206,7 +1206,7 @@ func (r *parquetReader[M, P]) columnIter(ctx context.Context, columnName string,
12061206
return query.NewErrIterator(fmt.Errorf("column '%s' not found in parquet file '%s'", columnName, r.relPath()))
12071207
}
12081208
ctx = query.AddMetricsToContext(ctx, r.metrics.query)
1209-
return query.NewColumnIterator(ctx, r.file.RowGroups(), index, columnName, 1000, predicate, alias)
1209+
return query.NewSyncIterator(ctx, r.file.RowGroups(), index, columnName, 1000, predicate, alias)
12101210
}
12111211

12121212
func repeatedColumnIter[T any](ctx context.Context, source Source, columnName string, rows iter.Iterator[T]) iter.Iterator[*query.RepeatedRow[T]] {

0 commit comments

Comments
 (0)