Hello Cloudera Community, I am currently working with a NiFi workflow that includes a PutDistributedMapCache (version 1.19.1) processor with a Cache Update Strategy set to "Replace if Present". This processor sets the value for the key "token". Additionally, I am using a DistributedMapCacheServer with a First In, First Out (FIFO) Eviction Strategy and a Maximum Cache Entries setting of 500. In my workflow, there are four subprocess groups, each processing 185 flowfiles. Each group has a Wait processor that ensures the previous group has finished processing its files before starting its own processing. Following these sub process groups, I have a FetchDistributedMapCache processor to fetch the Cache Entry Identifier "token". However, I am encountering an issue where several files are fetching the old "token" at the FetchDistributedMapCache step instead of the new token. Could anyone provide insights or suggestions on why this might be happening and how to resolve this issue? Thanks in advance for your help! ... View more