Я пытаюсь вставить записи о друидах с помощью Nifi. Процессоры PutDruidRecord имеют 3 вида выходных данных:
- success
- fail
- drop: FlowFiles перенаправляются в это отношение, когда они находятся за пределами сконфигурированного временного окна,неверный формат отметки времени, т. д. ...
Мои записи удаляются. Моя временная метка была сгенерирована ранее с помощью выражений nifi (now (): toNumber ()), и настроенное допустимое время задержки составляет 10 минут, поэтому это не может быть проблемой устаревшей записи.
Журналы приложения nifiне указывайте причину, по которой записи удаляются.
Как я могу выяснить причину удаления записей?
И последний вопрос: должен ли я предварительно создать какой-либо источник данных скакой-нибудь инструмент, прежде чем пытаться вставить данные с помощью Nifi или он создается автоматически?
Спасибо