Skip to content

Commit a52f8ce

Browse files
committed
changefeedccl: delete leftover comment
This patch deletes a leftover comment that should've been deleted in the commit that had aggregators periodically flush their progress. Release note: None
1 parent 7c19a98 commit a52f8ce

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

pkg/ccl/changefeedccl/changefeed_processors.go

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -932,12 +932,6 @@ func (ca *changeAggregator) noteResolvedSpan(resolved jobspb.ResolvedSpan) error
932932

933933
forceFlush := resolved.BoundaryType != jobspb.ResolvedSpan_NONE
934934

935-
// NB: if we miss flush window, and the flush frequency is fairly high (minutes),
936-
// it might be a while before frontier advances again (particularly if
937-
// the number of ranges and closed timestamp settings are high).
938-
// TODO(yevgeniy): Consider doing something similar to how job checkpointing
939-
// works in the frontier where if we missed the window to checkpoint, we will attempt
940-
// the checkpoint at the next opportune moment.
941935
checkpointFrontier := (advanced && forceFlush) || ca.frontierFlushLimiter.canSave(ctx)
942936

943937
if checkpointFrontier {

0 commit comments

Comments
 (0)