nifi FlowFile 尚未关闭（Groovy 脚本）警告

Question

nifi 术语和流文件处理的新手。

找到了一种方便的方法来处理传入的 xml 并使用 XmlSlurper 对其进行解析，但是对于传入流文件的以下 GroovyScript 收到警告-

流程：

处理器详细信息：

脚本正文：

def flowFile = session.get()
if(!flowFile) return
InputStream i = flowFile.read()
new XmlSlurper().parse(i)
i.close()
REL_SUCCESS << flowFile

似乎是处理流文件的问题。有人可以解释这里到底发生了什么以及如何最好地处理它吗？似乎这导致集群有时挂起

Answer 1

使用try-catch或withStream关闭流，即使发生错误也是如此：

def flowFile = session.get()
if(!flowFile) return
def xml = flowFile.read().withStream{i->
    new XmlSlurper().parse(i)
}
REL_SUCCESS << flowFile