-
Notifications
You must be signed in to change notification settings - Fork 18
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
Fixes issue-257: Sets write consistency on Batch statement #258
base: main
Are you sure you want to change the base?
Conversation
@arvy could you update the manual testing steps on this PR description for future reference? Thanks for the PR! |
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.
Hi, Thanks for looking into this, however I think it is not needed as the individual statements within the batch are already set with the right consistency-level. See TargetUpdateStatement
& TargetInsertStatement
for details.
Did you observe an issue with the write-consistency?
Sorry, I did not see your earlier comments, & looks like batches are ignoring consistency on individual statements. |
More context on my urgency: Sony has described many issues with inconsistent discrepancies when running validation job, which were most likely due to this bug (Datastax support case 00091967) |
I would be suspicious if you are seeing many issues as we have not found evidence of such issues for other customers & we have done many migrations as well as validations for very large clusters. If the target env is Astra, then write consistency issue is not possible as Astra will auto use |
Sets consistency level on batch statements:
Which issue(s) this PR fixes:
Fixes #257
I have tested this manually, using query tracing - I have validated that this is indeed an issue and this PR does fix it.
Any ideas for an automated test welcome :)
Steps for manual acceptance test:
cqlsh> TRUNCATE system_traces.sessions; TRUNCATE system_traces.events;
)nodetool settraceprobability 1.0
)cqlsh> select * from system_traces.sessions
)