我有一个Nifi Flow,它将获取Active NameNode,并将NN ip放入Flow文件属性。现在我想在下一个应用程序中使用NN属性,这是一个fetchHDFS处理器。
但是队列中的流文件似乎没有流过FetchHDFS处理器。
这是Flow File的属性,我对host_ip感兴趣,Host_name
更新
我想动态更改hdfs路径/ActiveNN等以获取数据,因此所有这些信息都将出现在流文件属性中。
下图是我的要求,路径和host_ip将出现在流文件属性中,如果fetchHDFS不是正确的方式,我该如何实现这一点。
FetchHDFS
配置属性没有指定host_ip、Host_name等的选项。要正确配置它,我们必须提供包含Hadoop文件系统配置的文件,即core-site. xml
和hdfs-site.xml
,如果您的Hadoop集群使用任何身份验证机制,那么您也需要提供这些详细信息。请参考下面的工作配置截图,从任何Hadoop数据节点复制这些文件并粘贴到NiFi节点(或NiFi集群设置的所有节点)上,并通过Hadoop集群身份验证详细信息(如果有)。