diff --git a/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink.go b/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink.go index 543cd0184b6..c4e8d84e01b 100644 --- a/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink.go +++ b/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink.go @@ -164,7 +164,7 @@ func (d *DDLSink) bgCleanup(ctx context.Context, cleanupJob func()) { zap.String("namespace", d.id.Namespace), zap.String("changefeedID", d.id.ID), zap.String("date-separator", d.cfg.DateSeparator), - zap.Duration("expired-file-ttl", d.cfg.FileExpirationDays)) + zap.Int("expired-file-ttl", d.cfg.FileExpirationDays)) return } @@ -176,7 +176,7 @@ func (d *DDLSink) bgCleanup(ctx context.Context, cleanupJob func()) { zap.String("namespace", d.id.Namespace), zap.String("changefeedID", d.id.ID), zap.String("date-separator", d.cfg.DateSeparator), - zap.Duration("expired-file-ttl", d.cfg.FileExpirationDays)) + zap.Int("expired-file-ttl", d.cfg.FileExpirationDays)) // wait for the context done <-ctx.Done()