diff --git a/pkg/ccl/streamingccl/streamingest/stream_ingestion_frontier_processor.go b/pkg/ccl/streamingccl/streamingest/stream_ingestion_frontier_processor.go index 795149253fcd..765b5b1b1808 100644 --- a/pkg/ccl/streamingccl/streamingest/stream_ingestion_frontier_processor.go +++ b/pkg/ccl/streamingccl/streamingest/stream_ingestion_frontier_processor.go @@ -538,11 +538,7 @@ func (sf *streamIngestionFrontier) maybePersistFrontierEntries() error { func (sf *streamIngestionFrontier) maybeCheckForLaggingNodes() error { ctx := sf.Ctx() - - // We halve the frequency relative to the ReplanFrequency setting (i.e. - // check twice as often), because the node lag checker will only restart the - // distSQL plan if a node is lagging for 2 checks in a row. - checkFreq := streamingccl.ReplanFrequency.Get(&sf.FlowCtx.Cfg.Settings.SV) / 2 + checkFreq := streamingccl.LagCheckFrequency.Get(&sf.FlowCtx.Cfg.Settings.SV) maxLag := streamingccl.InterNodeLag.Get(&sf.FlowCtx.Cfg.Settings.SV) if sf.persistedReplicatedTime.IsEmpty() { log.VEvent(ctx, 2, "skipping lag replanning check: no persisted replicated time")