Nifi DistributedCache查找问题

我配置了一个流程如下：

1. GetFile
2. SplitText-> 分割成流文件
3. ExtractText-> 使用两个键添加属性
4. PutDistributedMapCache-> 缓存条目标识符是 ${Key1}_${Key2}

现在我配置了一个示例GenerateFlowFile它生成一个样本记录，然后进入LookupRecord ( concat(/Key1,'_',/Key2))它在缓存中查找相同的键。

我在缓存流程中发现了一个问题，因为当我配置GenerateFlowFile来缓存相同的记录时，我能够进行查找

此流程无法查找。请帮忙

Flow is:

PutDistributedMapCache

提取文本

查找流程

查找记录配置

我总共添加了四个键，因为这是我的业务用例。

我有一个包含 53 条记录的 csv 文件，我使用 Splitfile 来拆分每条记录并添加属性，这些属性充当我存储在 PutDistributedMapcache 中的密钥。现在我有一个不同的流程，我从GenerateFlowFile开始，它生成如下记录：

因此，我希望我的 LookupKeyRecord 具有 jsonreader 和 jsonwriter 来读取此记录，使用分布式缓存中的键进行查找并填充我的记录中的 /Feedback 字段。

这无法查找记录，并且记录显示为“不匹配”。

现在的问题是，假设我删除了 GetFile 并使用具有此配置的GenerateFlowFile 来缓存：

所以我的查找使用键 9_9_9_9。但是当我添加另一组具有不同键的记录时，我的查找失败。

我发现，我的 DistributedMapCache 服务器的最大缓存条目默认配置为 1。我增加了它，它现在可以工作了:)