java - Apache NiFi : FlowFileHandlingException when transfer FlowFile in custom processor

Question

我在我的自定义 NiFi 处理器中从远程 API 服务获取不同时间范围的数据。

我有时间范围全局计数器，每次迭代都会更新(我正在使用计时器驱动的调度策略)。

当计数器大于最大值时，我想仅从请求(session.get())传输FlowFile，并且SUCCESS> 关系，即不执行额外的逻辑:

session.transfer(requestFlowFile, SUCCESS);

我知道当时间范围收集结束时我无法停止或暂停处理器。所以我尝试使用上述方法作为解决方案。

所有迭代都会顺利进行，直到计数器大于最大值并且处理器尝试从请求传输 FlowFile (session.get())

所以我有这个异常(exception):

由于org.apache.nifi.processor.exception.FlowFileHandlingException而无法处理 session :StandardFlowFileRecord[uuid=459e615b-0ff5-424f-aac7-f95d364cdc13，claim=，offset=0，name=99628180019265，size=0]在本次 session 中未知

这里出了什么问题？或者可能是另一种方法？

Answer 1

该错误意味着传递给 session.transfer() 的流文件来自不同的 session 。您只能在调用 get() 的同一个 session 上调用 Transfer()。