-
Notifications
You must be signed in to change notification settings - Fork 588
HDDS-13418. Add Flushed Transaction Info as part of OM Double Buffer Flush #8779
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
Conversation
…h write Change-Id: I65444c0155b471c31ea1283d563d9a948f5e4005
…impact Change-Id: I3b34e1bb6ca7587243f6eef176c396ca0132dbc3
Change-Id: Iab23d0b1316eac9c376fd06226d234b97e908b4f
Change-Id: I74fed5aebb5c0588cbf97f70a0f9acf94edfa87c
… rocksdb Change-Id: Ic123641dcb78c53917d9db922cdaace9649d12b0
…Flush Change-Id: I6effb3bd53ad0c29884d2c32d900a17ebb501243
|
Please wait for the other PR (#8778) to be merged before opening the dependent one. PRs should not be sitting in the queue. |
| omMetadataManager.getFlushedTransactionsTable().deleteRangeWithBatch(batchOperation, 0L, | ||
| Math.max(lastTransaction.getIndex() - maxFlushedTransactionGap, 0L)); |
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.
This can be used in event notification design as well.
| () -> response.checkAndUpdateDB(omMetadataManager, batchOperation)); | ||
| addToBatchWithTrace(omResponse, () -> { | ||
| response.checkAndUpdateDB(omMetadataManager, batchOperation); | ||
| omMetadataManager.getFlushedTransactionsTable().putWithBatch(batchOperation, entry.termIndex.getIndex(), |
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.
flush as part of double buffer batch
What changes were proposed in this pull request?
As part of the OM Double Buffer flush, an entry corresponding to each transaction flushed should be added to the flushedTransactionsTable in OM rocksdb.
What is the link to the Apache JIRA
https://issues.apache.org/jira/browse/HDDS-13418
How was this patch tested?
Additional unit test to be added.