File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1566,7 +1566,7 @@ func (q *Querier) GetProfileMetadataMappings(
15661566 records := make (map [string ]struct {})
15671567 err = q .engine .ScanTable (q .tableName ).
15681568 Filter (filterExpr ).
1569- Project (logicalplan .Col ("stacktrace" )).
1569+ Distinct (logicalplan .Col ("stacktrace" )).
15701570 Execute (ctx , func (ctx context.Context , r arrow.Record ) error {
15711571 r .Retain ()
15721572
@@ -1631,7 +1631,7 @@ func (q *Querier) GetProfileMetadataLabels(
16311631
16321632 err = q .engine .ScanTable (q .tableName ).
16331633 Filter (filterExpr ).
1634- Project (logicalplan .DynCol ("labels" )).
1634+ Distinct (logicalplan .DynCol ("labels" )).
16351635 Execute (ctx , func (ctx context.Context , ar arrow.Record ) error {
16361636 for i , field := range ar .Schema ().Fields () {
16371637 nulls := ar .Column (i ).NullN ()
You can’t perform that action at this time.
0 commit comments