remove redundant logging

jgao54 · jgao54 · commit cbc422f51d75 · 2025-11-12T14:16:46.000-10:00
diff --git a/flow/connectors/mysql/mysql.go b/flow/connectors/mysql/mysql.go
@@ -526,7 +526,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
`@@ -526,7 +526,6 @@ func (c *MySqlConnector) GetTableSizeEstimatedBytes(ctx context.Context, fullyQu`
`526`	`526`
`527`	`527`	`rs, err := c.Execute(ctx, query)`
`528`	`528`	`if err != nil {`
`529`		`- c.logger.Warn("failed to get estimated table size", slog.Any("error", err))`
`530`	`529`	`return 0, err`
`531`	`530`	`}`
`532`	`531`	`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 {`