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。我的问题主要是关于命名约定。