Я пытаюсь использовать Nifi 1.7 с процессором Hive 3.0 и PutHive3Streaming.В моем случае записи передаются в Failed queue без каких-либо сообщений ERROR на Nifi.
В журналах Hive-metastore тоже нет ничего значительного для сообщения.
Что-то интересное, что я заметил в трассировке журнала nifi, это статистика: records-written: 1,committed-transactions: 0
Трассировка журнала Nifi:
Closed streaming connection. Agent: NiFi PutHive3Streaming [1b137530-0166-1000-67c9-15cea37724a5] thread 59[Timer-Driven Process Thread-5] Stats: {records-written: 1, records-size: 0, committed-transactions: 0, aborted-transactions: 0, auto-flushes: 0, metastore-calls: 7 }
Я собрал процессоры PutHive3Streaming из ветви support / nifi-1.7.x из https://github.com/apache/nifi/tree/support/nifi-1.7.x
Хорошо ли использовать версию 1.7 и, в частности, процессоры hive3.0 в производстве?