From 1f1dee82828c288df1bf54417104d7036544627d Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Sat, 9 Mar 2024 11:21:49 -0500 Subject: [PATCH] remove rogue log and add a useful one --- flow/connectors/postgres/cdc.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index adb6c5daab..4683adb072 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -705,8 +705,9 @@ func (p *PostgresCDCSource) processRelationMessage( currRel *pglogrepl.RelationMessage, ) (model.Record, error) { // not present in tables to sync, return immediately - p.logger.Warn("hello!", slog.Any("mapping", p.srcTableIDNameMapping), slog.Any("currRel", currRel)) if _, ok := p.srcTableIDNameMapping[currRel.RelationID]; !ok { + p.logger.Info("relid not present in srcTableIDNameMapping, skipping relation message", + slog.Uint64("relId", uint64(currRel.RelationID))) return nil, nil }