我对NiFi非常陌生,我只是在玩处理器。
我正在尝试在测试中合并Wait
和Notify
处理器,但是我必须设置一个分布式Map (服务器和客户机?)。
NiFi文档假定了我所不具备的理解水平。
我已经在我的计算机(macOS)上安装了memcached,并验证了它是否运行在端口11211 (默认)上。我在NiFi的DistributedMapCacheClientService
和DistributedMapCacheServer
下创建了一个CONTROLLER SERVICES
,但是我得到了java.net.SocketTimeoutException
&其他错误。
有关于整个主题的好教程吗?有人能建议如何前进吗?
发布于 2017-06-16 14:34:27
DistributedMapCacheClientService
和DistributedMapCacheServer
不需要额外的软件。
要创建这些服务,右键单击画布,选择Configure
,然后选择Controller Services
选项卡。然后,您可以通过单击右边的+
按钮并按名称进行搜索来添加新服务。
DistributedMapCacheServer
并启用它。这将启动内置缓存服务器。DistributedMapCacheClientService
和其他默认参数创建localhost
并启用它GenerateFlowFile
,设置run schedule
,而不是参数中的零字节大小。将其连接到PutDistributedMapCache
,将Entry Identifier
设置为Key01
并选择DistributedMapCacheClientService
试着运行它。如果其他软件不使用端口4557,则put缓存应该可以工作。
发布于 2020-10-21 15:28:07
@Darshan将起作用,因为在DistributedMapCacheClientService
的文档中说:
提供与DistributedMapCacheServer通信的能力。这可以用于在NiFi集群中的节点之间共享一个映射
https://stackoverflow.com/questions/44590296
复制相似问题