清除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腳本以啓用該功能。