Я хотел бы вставить данные в таблицу улья, используя NiFi.
Лучший и самый простой вариант, который я видел, это использовать процессор PutHiveStreaming. Мне известны настройки, которые необходимо соблюдать, чтобы использовать этот процессор; некоторые из них касаются таблицы улья, которые можно сделать во время создания таблицы, а некоторые - о свойствах улья, таких как:
- hive.txn.manager = org.apache.hadoop.hive.ql.lockmgr.DbTxnManager
- hive.compactor.initiator.on = true
- hive.compactor.worker.threads> 0
Я установил эти свойства в hive-site.xml в нашем каталоге $ HADOOP_HOME / conf и указал полный путь к этому процессору в разделе «Ресурсы конфигурации Hive». Однако эти свойства в hive-site.xml не обрабатываются этим процессором.
Конфигурация PutHiveStreaming
К сожалению, у нас нет разрешения на $ HIVE_HOME / conf или / etc / hive / conf для прямого изменения hive-site.xml.
Может ли кто-нибудь объяснить, почему свойства hive-site.xml, предоставленные этому процессору, не используются, и что может быть обходным путем в переопределении свойств улья при использовании NiFi? то есть: есть ли способ выполнить несколько запросов для данного файла потока?