-
Notifications
You must be signed in to change notification settings - Fork 6
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
Request transfer transactions in parallel #125
Conversation
scalardb/project.clj
Outdated
@@ -9,7 +9,8 @@ | |||
[org.slf4j/slf4j-jdk14 "2.0.6"] | |||
[cassandra "0.1.0-SNAPSHOT"] | |||
[cheshire "5.12.0"] | |||
[com.scalar-labs/scalardb-schema-loader "4.0.0-SNAPSHOT"]] | |||
[com.scalar-labs/scalardb-schema-loader "4.0.0-SNAPSHOT" | |||
:exclusions [org.slf4j/*]]] |
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.
Thanks for taking care of the issue!
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.
It was fixed by scalar-labs/scalardb#1665.
Reverted.
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.
Ah, I see. Understood.
[test op transfer-fn] | ||
(let [results (pmap #(transfer-fn test %) (:value op))] | ||
(if (some #{:commit} results) | ||
;; return :ok when at least 1 transaction is committed |
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.
:ok
needs to be returned for this filtering even if only one transaction is committed?
(r/filter op/ok?) |
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.
Right, it's just for the checker, Jepsen requires the type though
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.
LGTM! Thank you!
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.
LGTM! Thank you!
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.
LGTM! Thank you!
Description
Each worker's ScalarDB transaction service requested transactions one by one though there are multiple workers.
This PR changes the transaction request to execute multiple transactions at once.
We can test concurrent transactions in more practical cases, especially for the group commit.
Related issues and/or PRs
Changes made
transfer
max-num-txs
to request transactions at onceChecklist
Additional notes (optional)