DomGarguilo commented on a change in pull request #2304:
URL: https://github.com/apache/accumulo/pull/2304#discussion_r723594617
##########
File path:
test/src/main/java/org/apache/accumulo/test/functional/ConcurrentDeleteTableIT.java
##########
@@ -269,12 +228,53 @@ protected void doTableOp() throws Exception {
}
}
+ private abstract static class DelayedTableOp implements Runnable {
+ private final CountDownLatch cdl;
+
+ DelayedTableOp(CountDownLatch cdl) {
+ this.cdl = cdl;
+ }
+
+ @Override
+ public void run() {
+ try {
+ cdl.countDown();
+ cdl.await();
+ Thread.sleep(10);
+ doTableOp();
+ } catch (TableNotFoundException | TableOfflineException e) {
+ // expected
+ } catch (RuntimeException e) {
+ throw e;
+ } catch (Exception e) {
+ if (e.getCause().getClass().equals(ThriftTableOperationException.class)
+ && e.getMessage().equals("Table is being deleted")) {
Review comment:
Addressed in 873e5d1. Needed to add it to `TableOperationsImpl` since
`CompactionDriver` is private.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
