in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java [149:175]
private void writeEventBatchToSerializer()
throws InterruptedException, WriteException {
try {
timedCall(new CallRunner1<Void>() {
@Override
public Void call() throws InterruptedException, StreamingException {
try {
for (Event event : batch) {
try {
serializer.write(txnBatch, event);
} catch (SerializationError err) {
LOG.info("Parse failed : {} : {}", err.getMessage(), new String(event.getBody()));
}
}
return null;
} catch (IOException e) {
throw new StreamingIOFailure(e.getMessage(), e);
}
}
});
batch.clear();
} catch (StreamingException e) {
throw new WriteException(endPoint, txnBatch.getCurrentTxnId(), e);
} catch (TimeoutException e) {
throw new WriteException(endPoint, txnBatch.getCurrentTxnId(), e);
}
}