t1.commit();
fail();
} catch (TransactionSerializableConflictException e) {
}
}
<BUG>@Test(expected=TransactionFailedRetriableException.class)
</BUG>
public void testConcurrentWriteSkew() throws InterruptedException, BrokenBarrierException {
Transaction t0 = startTransaction();
put(t0, "row1", "col1", "100");

t1.commit();
}
@Test
public void testClassicWriteSkew() {
Transaction t0 = startTransaction();
put(t0, "row1", "col1", "100");
