Skip to content

Commit 2526c4b

Browse files
committed
crosscluster: fix error handling in computeRangeStats
`computeRangeStats` was returning `err` when it should have returned `lazyIterator.Error`. The code calling this is best effort, so returning success is not a critical bug. But it does mean we would miss a warning log. Release note: none Epic: none
1 parent c1e847b commit 2526c4b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/crosscluster/producer/range_stats.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ func computeRangeStats(
108108
}
109109
}
110110
if lazyIterator.Error() != nil {
111-
return streampb.StreamEvent_RangeStats{}, err
111+
return streampb.StreamEvent_RangeStats{}, lazyIterator.Error()
112112
}
113113
}
114114
return stats, nil

0 commit comments

Comments
 (0)