Тестирование агента flume для передачи файлов при сбое кластера cloudera (служба flume была остановлена).Файл в каталоге спула источника был помечен как завершенный.Используемый источник - каталог спулинга, канал - файловый канал, а приемник - hdfs.
Насколько я понимаю, поведение является транзакционным, то есть до тех пор, пока записи не будут записаны в приемник, файл в директории исходного каталога не должен быть помечен как завершенный.