private void processErrors() throws IOException {
      RowErrorsAndOverflowStatus pendingErrors = session.getPendingErrors();
      if (pendingErrors.getRowErrors().length != 0) {
        RowError[] errors = pendingErrors.getRowErrors();
        // Build a sample of error strings.
        int sampleSize = 5;
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < errors.length; i++) {
          if (i == sampleSize) {
            break;
          }
          sb.append(errors[i].getErrorStatus().toString());
        }
        if (pendingErrors.isOverflowed()) {
          throw new IOException(
              "PendingErrors overflowed. Failed to write at least " + errors.length + " rows " +
                  "to Kudu; Sample errors: " + sb.toString());
        } else {
          throw new IOException(
              "Failed to write " + errors.length + " rows to Kudu; Sample errors: " +
                  sb.toString());
        }
      }
    }
A Kudu OutputFormatKuduPredicateHandler implementation for use by Hive.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduOutputFormat.java