From 879a89a05550fca5287ac60f96d4d4903ca3786e Mon Sep 17 00:00:00 2001 From: David Taylor Date: Sat, 9 Nov 2024 16:02:36 +0000 Subject: [PATCH] crosscluster/logical: elide status msg when caught up Release note: none. Epic: none. --- pkg/ccl/crosscluster/logical/range_stats.go | 2 +- pkg/ccl/crosscluster/logical/range_stats_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/ccl/crosscluster/logical/range_stats.go b/pkg/ccl/crosscluster/logical/range_stats.go index 473d6c5a6b54..0fd66dd281d8 100644 --- a/pkg/ccl/crosscluster/logical/range_stats.go +++ b/pkg/ccl/crosscluster/logical/range_stats.go @@ -54,7 +54,7 @@ func (r *rangeStatsByProcessorID) RollupStats() (streampb.StreamEvent_RangeStats if total.LaggingRangeCount != 0 { return total, fractionCompleted, fmt.Sprintf("catching up on %d out of %d ranges", total.LaggingRangeCount, total.RangeCount) } - return total, 1, fmt.Sprintf("all %d ranges are caught up", total.RangeCount) + return total, 1, "" } func newRangeStatsCollector(processorCount int) rangeStatsByProcessorID { diff --git a/pkg/ccl/crosscluster/logical/range_stats_test.go b/pkg/ccl/crosscluster/logical/range_stats_test.go index abcc2ff9d5e8..1e39b5f15915 100644 --- a/pkg/ccl/crosscluster/logical/range_stats_test.go +++ b/pkg/ccl/crosscluster/logical/range_stats_test.go @@ -32,7 +32,7 @@ func TestRangeStats(t *testing.T) { RangeCount: 10, }, fraction: 1, - expectedMsg: "all 10 ranges are caught up", + expectedMsg: "", inputStats: map[int32]*streampb.StreamEvent_RangeStats{ 1: {RangeCount: 5}, 2: {RangeCount: 3},