remove redundant logging

jgao54 · jgao54 · commit b0598243f710 · 2025-11-14T09:34:07.000-10:00
diff --git a/flow/connectors/mysql/mysql.go b/flow/connectors/mysql/mysql.go
@@ -529,7 +529,6 @@ func (c *MySqlConnector) GetTableSizeEstimatedBytes(ctx context.Context, fullyQu
 
 	rs, err := c.Execute(ctx, query)
 	if err != nil {
-		c.logger.Warn("failed to get estimated table size", slog.Any("error", err))
 		return 0, err
 	}
 	defer rs.Close()
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -1808,7 +1808,6 @@ func (c *PostgresConnector) GetTableSizeEstimatedBytes(ctx context.Context, full
 	tableSizeQuery := "SELECT pg_relation_size(to_regclass($1))"
 	var tableSizeBytes pgtype.Int8
 	if err := c.conn.QueryRow(ctx, tableSizeQuery, fullyQualifiedTableName).Scan(&tableSizeBytes); err != nil {
-		c.logger.Warn("failed to get estimated table size", slog.Any("error", err))
 		return 0, err
 	}
 	if !tableSizeBytes.Valid {

Original file line number	Diff line number	Diff line change
`@@ -529,7 +529,6 @@ func (c *MySqlConnector) GetTableSizeEstimatedBytes(ctx context.Context, fullyQu`
`529`	`529`
`530`	`530`	`rs, err := c.Execute(ctx, query)`
`531`	`531`	`if err != nil {`
`532`		`- c.logger.Warn("failed to get estimated table size", slog.Any("error", err))`
`533`	`532`	`return 0, err`
`534`	`533`	`}`
`535`	`534`	`defer rs.Close()`
Original file line number	Diff line number	Diff line change
`@@ -1808,7 +1808,6 @@ func (c *PostgresConnector) GetTableSizeEstimatedBytes(ctx context.Context, full`
`1808`	`1808`	`tableSizeQuery := "SELECT pg_relation_size(to_regclass($1))"`
`1809`	`1809`	`var tableSizeBytes pgtype.Int8`
`1810`	`1810`	`if err := c.conn.QueryRow(ctx, tableSizeQuery, fullyQualifiedTableName).Scan(&tableSizeBytes); err != nil {`
`1811`		`- c.logger.Warn("failed to get estimated table size", slog.Any("error", err))`
`1812`	`1811`	`return 0, err`
`1813`	`1812`	`}`
`1814`	`1813`	`if !tableSizeBytes.Valid {`