diff --git a/internal/database/compaction_types.go b/internal/database/compaction_types.go
index 4a2f98e1..bf052f7e 100644
--- a/internal/database/compaction_types.go
+++ b/internal/database/compaction_types.go
@@ -17,7 +17,7 @@ func getTimeRangesToReorder(ctx context.Context, db *DuckDb, pk *partitionKey, r
 	if reindex {
 		rm, err := newReorderMetadata(ctx, db, pk)
 		if err != nil {
-			return nil, fmt.Errorf("failed to retiever stats for partition key: %w", err)
+			return nil, fmt.Errorf("failed to retrieve stats for partition key: %w", err)
 		}
 
 		// make a single time range
@@ -52,7 +52,7 @@ func getTimeRangesToReorder(ctx context.Context, db *DuckDb, pk *partitionKey, r
 	// get stats for the partition key
 	rm, err := newReorderMetadata(ctx, db, pk)
 	if err != nil {
-		return nil, fmt.Errorf("failed to retiever stats for partition key: %w", err)
+		return nil, fmt.Errorf("failed to retrieve stats for partition key: %w", err)
 	}
 	rm.unorderedRanges = unorderedRanges
 	return rm, nil
diff --git a/internal/database/tables.go b/internal/database/tables.go
index 4d8f7acb..a38c1485 100644
--- a/internal/database/tables.go
+++ b/internal/database/tables.go
@@ -113,6 +113,11 @@ func GetLegacyTableViewSchema(ctx context.Context, viewName string, db *DuckDb)
 			return nil, fmt.Errorf("failed to scan column schema: %w", err)
 		}
 
+		// NOTE: legacy tailpipe views may include `rowid` which we must exclude from the schema as this is a DuckDb system column
+		// that is automatically added to every table
+		if columnName == "rowid" {
+			continue
+		}
 		col := buildColumnSchema(columnName, columnType)
 		ts.Columns = append(ts.Columns, col)
 	}