private void abortRemainingTxns()

in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java [263:288]

24 lines of code
5 McCabe index (conditional complexity)


  private void abortRemainingTxns() throws InterruptedException {
    try {
      if (!isClosed(txnBatch.getCurrentTransactionState())) {
        abortCurrTxnHelper();
      }

      // recursively abort remaining txns
      if (txnBatch.remainingTransactions() > 0) {
        timedCall(
            new CallRunner1<Void>() {
              @Override
              public Void call() throws StreamingException, InterruptedException {
                txnBatch.beginNextTransaction();
                return null;
              }
            });
        abortRemainingTxns();
      }
    } catch (StreamingException e) {
      LOG.warn("Error when aborting remaining transactions in batch " + txnBatch, e);
      return;
    } catch (TimeoutException e) {
      LOG.warn("Timed out when aborting remaining transactions in batch " + txnBatch, e);
      return;
    }
  }