in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java [263:288]
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;
}
}