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