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