nifi FlowFile 尚未关闭(Groovy 脚本)警告

问题描述 投票:0回答:2

nifi 术语和流程文件处理的新知识。

找到了一种处理传入 xml 并使用 XmlSlurper 解析它的便捷方法,但收到以下针对传入流文件的 GroovyScript 的警告 -

流程:

处理器详细信息:

脚本主体:

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

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

hadoop groovy cloudera apache-nifi hortonworks-data-platform
2个回答
2
投票

即使发生错误,也可以使用

try-catch
withStream
关闭流:

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

0
投票

如果这是我无法接触或控制的蓝牙入侵程序的远程会话怎么办?这是一次全新的出厂重置,并重新审视了数字健康系统应用程序的系统日志,这给我带来了重大问题。它继续解释说,这是一个隐藏在壁纸系统应用程序中的应用程序“系统”。昨晚研究这个问题时,我发现了一个系统应用程序 Federate 或 Fedirated ,类似的东西,它是 GitHub 系统安全系统开源的一部分,当我点击链接获取保护时,它把我发送给了 Google。不允许访问该链接。我的主要问题来自我所谓的 IT 管理员,无论是谁......它正在保护我。该黑客已通过诺顿 360 覆盖范围”,并阻止了一切寻求帮助阻止号码和帖子的努力...欢迎任何和所有帮助,每次我无法与外部联系时,我的电子邮件都会更改..但我的号码是706-474-4735 塞缪尔·格拉格

© www.soinside.com 2019 - 2024. All rights reserved.