-
Notifications
You must be signed in to change notification settings - Fork 3.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
changefeedccl: verify changefeed failure for reverted import #89169
changefeedccl: verify changefeed failure for reverted import #89169
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nice.
sqlDB.Exec(t, "INSERT INTO for_import VALUES (0, 10);") | ||
|
||
// Start an import job which will immediately pause after ingestion | ||
sqlDB.Exec(t, "SET CLUSTER SETTING jobs.debug.pausepoints = 'import.after_ingest';") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nice (@dt would be trilled to see this).
cdcTestNamed(t, "reverted import fails changefeed with earlier cursor", func(t *testing.T, s TestServer, f cdctest.TestFeedFactory) { | ||
sqlDB := sqlutils.MakeSQLRunner(s.DB) | ||
sqlDB.Exec(t, "SET CLUSTER SETTING kv.bulk_io_write.small_write_size = '1';") | ||
sqlDB.Exec(t, "SET CLUSTER SETTING storage.mvcc.range_tombstones.enabled = true;") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@miretskiy I assume the ConstantWithMetamorphicTestBool
on the cluster setting is something that applies to every test, so I'm wary of making a change like that here just for this test.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ack
0dd0569
to
f27f1f9
Compare
Resolves cockroachdb#82943 A new test verifies that even if an import was reverted the changefeed still fails on a table offline error. This is now needed to ensure we don't have undesired behavior during a case where rangefeeds would emit range tombstones. Release note: None
f27f1f9
to
29ce5b1
Compare
bors r+ |
Build succeeded: |
Resolves #82943
A new test verifies that even if an import was reverted the changefeed still fails on a table offline error. This is now needed to ensure we don't have undesired behavior during a case where rangefeeds would emit range tombstones.
Release note: None