nifi splitRecord hung

Question

我正在用一个只有11条记录的小文件测试nifi SplitRecord，但是，SplitRecord挂起很长时间。我不知道它在做什么。洪处理器

SPlitRecord属性： 更多属性

记录每次分割是否控制最大值，或最小记录，或每分割记录的确切数量？如果记录总数少于每次拆分的记录数，那么SplitRecords的行为是什么？它是等到暂停，然后把所有的记录放在一个单独的分裂？

经过大约10分钟或随机次数的开始/停止/终止/重新启动，它可能会触发处理器更快地拆分数据。

Answer 1

每个拆分记录控制的最大值，请参阅"SplitRecord.java“的代码。如果记录少于RECORDS_PER_SPLIT值，它将立即将它们全部推送出去。

但是，它看起来确实是在创建一个新的FlowFile，即使总记录计数小于RECORDS_PER_SPLIT值，这意味着它正在进行磁盘写入，而不管是否真的发生了拆分。

我可能会调查两件事：

1. 主机内存-主机有多少内存？有多少配置为NiFi最大堆？系统内存使用/空闲的总量是多少？当大量的系统内存留给文件缓存时，NiFi的性能最好。
2. 主机的磁盘，特别是其中包含内容存储库的磁盘。容量？伊欧？它是否与其他服务共享？FlowFile内容被写入到content，如果磁盘与OS共享，或者其他繁忙的服务(或其他NiFi repos)，它确实会减缓内容修改的速度。

注:您的NiFi版本超过3年，请考虑升级。