Skip to content

Commit 40b0345

Browse files
committed
fix: sync column index
1 parent b0a38f6 commit 40b0345

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

table.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,10 +200,11 @@ func (ts *STableSpec) SyncColumnIndexes() error {
200200
removed := []string{}
201201
for _, col := range cols {
202202
if _, ok := colsName[col.Name()]; !ok {
203+
ts._columns = append(ts._columns, col)
203204
removed = append(removed, col.Name())
204205
}
205206
}
206-
return errors.Wrapf(errors.ErrInvalidStatus, "ts %s col %d != actual col %d need remove columns %s", ts.Name(), len(ts._columns), len(cols), removed)
207+
log.Warningf("ts %s col %d != actual col %d need remove columns %s", ts.Name(), len(ts._columns)-len(removed), len(cols), removed)
207208
}
208209
for i := range cols {
209210
cols[i].SetColIndex(i)

0 commit comments

Comments
 (0)