-
Notifications
You must be signed in to change notification settings - Fork 448
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
Backport FateInterleavingIT to 3.1 #5223
base: 3.1
Are you sure you want to change the base?
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.
Briefly looked through this and it looks good. Should maybe wait to merge this until we figure out what to do with #5214. I would also like to do a more thorough review later
store.reserve(txid); | ||
try { | ||
status = store.getStatus(txid); | ||
} finally { | ||
store.unreserve(txid, Duration.ZERO); | ||
} |
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.
is reserving required in order to get the status in 3.x?
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.
Yes.
accumulo/core/src/main/java/org/apache/accumulo/core/fate/ZooStore.java
Lines 403 to 407 in d0fb7f5
@Override | |
public TStatus getStatus(long tid) { | |
verifyReserved(tid); | |
return _getStatus(tid); | |
} |
assertEquals(2, subset.keySet().stream() | ||
.filter(k -> k.getColumnFamily().toString().equals("TXID:" + txid)).count()); |
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.
For this and similar assertions, could also ensure that the isReady call occurs before the call call.
No description provided.