apache-nifi - 在 Nifi 中使用 ConvertJSONToSQL 处理器时出错

标签 apache-nifi

我使用的是 2.5 HDP。我在 ConvertJSONToSQL 处理器中遇到问题,我尝试将批量(1GB)大小的 Avro 文件转换为 SQL 格式,首先我将 Avro 格式转换为 JSON 格式(通过使用 ConvertAvroToJSON 处理器),然后将 JSON 格式转换为 SQL 格式(通过使用ConvertJSONToSQL 处理器),当时我遇到了下面提到的问题。

enter image description here

enter image description here

最佳答案

首先,您尝试使用 Nifi 中存在的 SplitAvro 处理器将 Avro 格式文件的大容量大小拆分为较小的大小,然后将其转换为 json

配置SplitAvro处理器的处理器

configure processor of SplitAvro processor

欲了解更多信息,请关注此link

关于apache-nifi - 在 Nifi 中使用 ConvertJSONToSQL 处理器时出错,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46666820/

相关文章:

docker - Nifi : Could not write to StandardFlowfileRecord 中的错误

apache-nifi - 阻止(或剥离)FlowFile 内容

mysql - NiFi 中的命名约定

apache-nifi - 使用 NiFi Flowfiles 作为事件通知器

java - NiFi-1.0.0 - 加载 lua 脚本

mysql - 用户 'user' @'localhost' 的访问被拒绝(使用密码 : YES) in Apache Nifi

apache-nifi - 如何根据 SQL 查询结果过滤流文件?

hortonworks-data-platform - UI 未在 nifi 1.0.0 安全集群中打开

mysql - 如何使用 NiFi 解析/提取属性名称及其值

json - 是否可以使用 JOLT 连接 JSON 属性的值?