src/java/org/apache/cassandra/db/compaction/CompactionManager.java
// modified from DebuggableThreadPoolExecutor so that CompactionInterruptedExceptions are not logged
modified from DebuggableThreadPoolExecutor so that CompactionInterruptedExceptions are not logged
modified from DebuggableThreadPoolExecutor so that CompactionInterruptedExceptions are not logged
@Override
        public void afterExecute(Runnable r, Throwable t)
        {
            super.afterExecute(r,t);
            if (t == null)
                t = DebuggableThreadPoolExecutor.extractThrowable(r);
            if (t != null)
            {
                if (t instanceof CompactionInterruptedException)
                {
                    logger.info(t.getMessage());
                    logger.debug("Full interruption stack trace:", t);
                }
                else
                {
                    DebuggableThreadPoolExecutor.handleOrLog(t);
                }
            }
        }
@ Override public void afterExecute ( Runnable r , Throwable t ) { super . afterExecute ( r , t ) ; if ( t == null ) t = DebuggableThreadPoolExecutor . extractThrowable ( r ) ; if ( t != null ) { if ( t instanceof CompactionInterruptedException ) { logger . info ( t . getMessage ( ) ) ; logger . debug ( "Full interruption stack trace:" , t ) ; } else { DebuggableThreadPoolExecutor . handleOrLog ( t ) ; } } }
modified from DebuggableThreadPoolExecutor so that CompactionInterruptedExceptions are not logged
modified from DebuggableThreadPoolExecutor so that CompactionInterruptedExceptions are not logged