我将一个处理单个节点NiFi的流移到一个3节点的NiFi集群中,突然一个使用DistributedMapCache的等待处理器无法像预期的那样工作,这意味着无法从缓存中恢复一个值。为了确保该值存在于缓存中,我将缓存配置为使用一个持久目录,因此,经过一些测试之后,我能够检查缓存的内容,并认识到:
另一个测试是强制执行主节点中的流,在这种情况下,一切都按预期工作。
另一个测试是同时从所有节点写入缓存,只对主节点有效。
所以我的问题是:
发布于 2018-09-06 12:55:16
您不应该在DistributedMapCacheClientService中使用localhost,只需使用其中一个节点的主机名,那么所有客户端都将指向同一台服务器。
https://stackoverflow.com/questions/52199160
复制相似问题