diff --git a/pkg/ccl/changefeedccl/changefeed_processors.go b/pkg/ccl/changefeedccl/changefeed_processors.go index e38c3af1115d..b6d1dd8eef62 100644 --- a/pkg/ccl/changefeedccl/changefeed_processors.go +++ b/pkg/ccl/changefeedccl/changefeed_processors.go @@ -1974,7 +1974,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) }