Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Sometimes tests will fail when a local cluster is being shut down because a thread was interrupted. This seems to occur most around the disruptor queue consume-loop* in executor.clj. The error handler for that method does not deal with Interrupted type exceptions at all, instead it reports the error and shuts down the entire process. We should add in checks similar to other places that look for InterruptedException or InterruptedIOExcepion and ignore the Exception, but then shut down the thread.