private void maybeCheckInterrupt() throws HiveException {
    if (ownThread == null || --interruptCheckCounter > 0) return;
    if (ownThread.isInterrupted()) {
      throw new HiveException("Thread interrupted");
    }
    interruptCheckCounter = CHECK_INTERRUPT_PER_OVERFLOW_BATCHES;
  }
Forward the overflow batch and reset the batch.
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java