hadoop - 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