isClosed = true;
exService.shutdown();
try {
exService.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);
} catch (InterruptedException e) {
<BUG>LOGGER.log(LogLevel.WARN, "Execution Service shutdown is interrupted.", e);
}finally {</BUG>
flushNow();
out.close();
bufferQueue.clear();

isClosed = true;
exService.shutdown();
try {
exService.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);
} catch (InterruptedException e) {
LOGGER.log(LogLevel.WARN, Messages.getString("HDFS_ASYNC_SERVICE_SHUTDOWN_INTERRUPTED"), e);
}finally {
flushNow();
out.close();
bufferQueue.clear();
