nifi flowfile尚未关闭(groovy脚本)警告

dvtswwa3 于 2021-05-29 发布在 Hadoop

关注(0)|答案(1)|浏览(432)

nifi术语和流文件处理的新知识。
找到了一种方便的方法来处理传入的xml并使用xmlslurper对其进行解析，但是对于传入的流文件，下面的groovyscript会得到一个警告-
流程：

处理器详细信息：

脚本正文：

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

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

1条答案

使用 try-catch 或者 withStream 即使发生错误也要关闭流：

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