hortonworks-dataflow

0熱度

1回答

以下是我使用安全休息api的nifi作業。當我運行invokeHttp處理器，我收到以下異常： 2017-09-19 07:58:59,744 ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.standard.InvokeHTTP java.lang.NullPointerException: null at or

0熱度

1回答

由Kafka引起的NiFi工作流程中的瓶頸

我在Apache NiFi中使用Kafka作爲緩衝系統創建數據攝取工作流程。我有一個3節點集羣運行相同的工作流程，每個節點有4個核心。我依賴於將數據移入和移出不同卡夫卡主題的幾個實例，這是工作流程中速度最慢的部分，並且性能方面非常不一致，因爲兩個相同的測試可能會有高達100％工期增加。我們的發佈和使用Kafka處理器正在所有三個節點上運行，而我們的Kafka主題在三個經紀人中有3個分區。有沒

0熱度

1回答

Ambari指標收集器API

我正在使用Ambari指標收集器API來獲取有關我的HDF和HDP集羣的信息，但我正在努力尋找有關可用指標，它們的單位是什麼，以及它們的平均期限的良好文檔等。有誰知道我在哪裏可以找到這樣的資源？

1熱度

2回答

Hortonworks：如何管理用戶

我是Hadoop管理和Hortonworks Hadoop的新手。我的問題是在Hortonworks中管理用戶的常見做法是什麼。 Ambari允許我創建用戶，但公司如何將Ambari中的用戶映射到他們的用戶。我看到在Hortonworks中，我可以啓用Kerberos;這是否允許公司用戶（例如LDAP）使用相同的用戶名/密碼登錄到Hortonworks？我不在這裏尋找細節，但只是關於常用做法的一些

1熱度

1回答

帶Hive的NiFi PutHiveStreaming處理器：連接到EndPoint失敗

有人會用Nifi 1.3.0和Hive幫助解決這個問題。我發現與hive 1.2和Hive 2.1.1相同的錯誤。配置單元表格是分區,分區並存儲爲ORC格式。該分區是在hdfs上創建的，但寫入階段的數據失敗。請檢查日誌如下： [5:07 AM] papesdiop: Failed connecting to EndPoint {metaStoreUri='thrift://localhost:9

1熱度

1回答

獲取並消費NiFi

我看到一些處理器同時具有GetXXX和ConsumeXXX變體（例如GetKafka和ConsumeKafka）。何時通過ConsumeXXX通過GetXXX命名處理器？注意：我瞭解technical differences between ConsumeKafka and GetKafka。我的問題主要是關於命名約定。