private void cleanup(boolean isError) {
    cleanUpCurrentRead();
    if (!isError) return;
    for (VectorDeserializeOrcWriter asyncWriter : asyncWriters) {
      try {
        asyncWriter.interrupt();
      } catch (Exception ex) {
        LlapIoImpl.LOG.warn("Failed to interrupt an async writer", ex);
      }
    }
    asyncWriters.clear();
  }
This class only exists because Java doesn't have yield return. The original method
before this change only needed yield return-s sprinkled here and there; however,
Java developers are usually paid by class, so here we go.
llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/SerDeEncodedDataReader.java