Skip to content

Commit 5f8c0d6

Browse files
committed
changefeedccl: fix race in TestChangefeedSchemaChangeAllowBackfill
Release note: None
1 parent b4eee02 commit 5f8c0d6

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

pkg/ccl/changefeedccl/changefeed_test.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3036,7 +3036,6 @@ func TestChangefeedSchemaChangeAllowBackfill(t *testing.T) {
30363036
`drop_column: [2]->{"after": {"a": 2, "b": "2"}}`,
30373037
})
30383038
sqlDB.Exec(t, `ALTER TABLE drop_column DROP COLUMN b`)
3039-
sqlDB.Exec(t, `INSERT INTO drop_column VALUES (3)`)
30403039
ts := schematestutils.FetchDescVersionModificationTime(t, s.TestServer.Server, `d`, `public`, `drop_column`, 2)
30413040

30423041
// Backfill for DROP COLUMN b.
@@ -3047,7 +3046,8 @@ func TestChangefeedSchemaChangeAllowBackfill(t *testing.T) {
30473046
ts.AsOfSystemTime()),
30483047
})
30493048

3050-
// Insert 3 into drop_column
3049+
// Insert 3 into drop_column.
3050+
sqlDB.Exec(t, `INSERT INTO drop_column VALUES (3)`)
30513051
assertPayloadsStripTs(t, dropColumn, []string{
30523052
`drop_column: [3]->{"after": {"a": 3}}`,
30533053
})
@@ -3088,6 +3088,7 @@ func TestChangefeedSchemaChangeAllowBackfill(t *testing.T) {
30883088
// version 2. Then, when adding column c, it goes from 9->17, with the schema change being visible at
30893089
// the 7th step (version 15). Finally, when adding column d, it goes from 17->25 ith the schema change
30903090
// being visible at the 7th step (version 23).
3091+
// TODO(#142936): Investigate if this descriptor version hardcoding is sound.
30913092
dropTS := schematestutils.FetchDescVersionModificationTime(t, s.TestServer.Server, `d`, `public`, `multiple_alters`, 2)
30923093
addTS := schematestutils.FetchDescVersionModificationTime(t, s.TestServer.Server, `d`, `public`, `multiple_alters`, 15)
30933094
addTS2 := schematestutils.FetchDescVersionModificationTime(t, s.TestServer.Server, `d`, `public`, `multiple_alters`, 23)

0 commit comments

Comments
 (0)