diff --git a/pkg/ccl/changefeedccl/changefeed_processors.go b/pkg/ccl/changefeedccl/changefeed_processors.go index 2d0b3ac1e89f..d9fbfd05b7ff 100644 --- a/pkg/ccl/changefeedccl/changefeed_processors.go +++ b/pkg/ccl/changefeedccl/changefeed_processors.go @@ -1975,7 +1975,7 @@ func (cf *changeFrontier) manageProtectedTimestamps( return cf.frontier.Frontier() }() - if cf.spec.ProgressConfig.PerTableProtectedTimestamps { + if cf.spec.ProgressConfig != nil && cf.spec.ProgressConfig.PerTableProtectedTimestamps { return cf.managePerTableProtectedTimestamps(ctx, txn, &ptsEntries, highwater) }