Wie lösche ich den Cache von FetchDistributedMapCache Prozessor in Apache NiFi? Ich habe versucht, das persistente Verzeichnis zu löschen und habe auch versucht, ein neues Verzeichnis alle zusammen zu geben, aber es ruft immer noch alte Daten ab. Danke für Ihre Hilfe.Löschen Sie den Cache von FetchDistributedMapCache Prozessor
Sie sollten in der Lage sein, den DistributedMapCacheClient und DistributedMapCacheServer zu stoppen, dann den vorhandenen DistributedMapCacheServer zu löschen und einen neuen mit demselben Port wie den vorherigen zu erstellen, und dann die Sicherung zu starten.
In NiFi könnten Sie einen neuen DistributedMapCacheServer erstellen und stattdessen Ihren Prozessor darauf richten. Außerhalb von NiFi habe ich written a Groovy script, wo Sie mit dem DistributedMapCacheServer über die Befehlszeile interagieren können. Mit der API können Sie nur Einträge entfernen, die Ihnen bekannt sind. In der kommenden Version NiFi 1.2.0 werden Sie in der Lage sein, Einträge mithilfe eines regulären Ausdrucks für die Schlüssel zu entfernen (implementiert in NIFI-3627). An diesem Punkt werde ich das Groovy-Skript aktualisieren, um diese Funktion zu aktivieren.
Danke. Es hat mir geholfen, das Problem zu lösen. –