清除FetchDistributedMapCache处理器的缓存

Question

如何清除Apache NiFi中FetchDistributedMapCache处理器的缓存？ 我试图删除持续的目录，并试图一起给一个新的目录，但它仍然提取旧数据。谢谢你的帮助。

Answer 1

您应该能够停止DistributedMapCacheClient和DistributedMapCacheServer，然后删除现有的DistributedMapCacheServer并使用与前一个端口相同的端口创建一个新的，然后重新启动它们。

Answer 2

在NiFi内部，您可以创建一个新的DistributedMapCacheServer，并将其指向您的处理器。在NiFi之外，我有written a Groovy script，您可以从命令行与DistributedMapCacheServer进行交互。该API只允许你删除你知道的条目;在即将到来的NiFi 1.2.0版本中，您将能够使用正则表达式删除键值（在NIFI-3627中执行）。此时我将更新Groovy脚本以启用该功能。