diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
index 1320bf8a92..f76ebb480e 100644
--- a/flow/connectors/clickhouse/clickhouse.go
+++ b/flow/connectors/clickhouse/clickhouse.go
@@ -458,7 +458,7 @@ func (c *ClickHouseConnector) processTableComparison(dstTableName string, srcSch
 			}
 		}
 		if !found {
-			return fmt.Errorf("field %s not found in destination table", srcField.Name)
+			return fmt.Errorf("field %s not found in destination table %s", srcField.Name, dstTableName)
 		}
 	}
 	foundPeerDBColumns := 0