From 9470a0e95efc30a7f7a68378b24ffb9d366ed0a5 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Thu, 8 Feb 2024 17:48:40 -0500 Subject: [PATCH] add useful logging --- flow/connectors/postgres/cdc.go | 1 + 1 file changed, 1 insertion(+) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 8029b4ae60..5f17172e51 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -246,6 +246,7 @@ func (p *PostgresCDCSource) consumeStream( shutdown := utils.HeartbeatRoutine(p.ctx, func() string { jobName := p.flowJobName currRecords := cdcRecordsStorage.Len() + p.logger.Info(fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords)) return fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords) }) defer shutdown()